org.opentrafficsim.imb.observers

Class IMBObserver

java.lang.Object

org.opentrafficsim.imb.observers.IMBObserver

All Implemented Interfaces:

Observer

public class IMBObserver
extends Object
implements Observer

Copyright (c) 2013-2016 Delft University of Technology, PO Box 5, 2600 AA, Delft, the Netherlands. All rights reserved.
BSD-style license. See OpenTrafficSim License.

Version:

$Revision$, $LastChangedDate$, by $Author$, initial version Aug 19, 2016

Author:

Alexander Verbraeck, Peter Knoppers, Wouter Schakel

Field Summary

Fields inherited from interface org.opentrafficsim.imb.observers.Observer

CHANGE, DELETE, NEW

Constructor Summary

Constructors

Constructor and Description
IMBObserver(String host, int port, String modelName, int modelId, String federation) Construct a new connection for sending events to IMB.

Method Summary

Modifier and Type	Method and Description
boolean	postMessage(String eventName, int eventType, Object[] args) Compose a message containing the specified objects and send it to recipients.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

IMBObserver

public IMBObserver(String host,
                   int port,
                   String modelName,
                   int modelId,
                   String federation)
            throws Exception

Construct a new connection for sending events to IMB.

Parameters:

host - String; name of the IMB hub

port - int; port number of the IMB hub

modelName - String; local model name

modelId - int; model id

federation - String; federation on the IMB hub

Throws:

Exception - when a connection to the IMB hub could not be established

Method Detail

postMessage

public final boolean postMessage(String eventName,
                                 int eventType,
                                 Object[] args)
                          throws Exception

Compose a message containing the specified objects and send it to recipients.

Specified by:

postMessage in interface Observer

Parameters:

eventName - String; publication

eventType - int; one of NEW, CHANGE, or DELETE

args - Object[]; the objects to send

Returns:

boolean; true on success, false on failure

Throws:

Exception

toString

public final String toString()

Overrides:

toString in class Object