public class OutConnector extends Object implements OutConnector
OutConnector
implementation for the inprocess
transport.Activatable.State
Constructor and Description |
---|
OutConnector(Bus bus)
Creates a new out connector operating on a given bus instance.
|
Modifier and Type | Method and Description |
---|---|
void |
activate()
Activates all resources that belong to a specific object.
|
void |
deactivate()
Deactivate all resources that are owned by a specific object in order to
correctly tear down.
|
protected Bus |
getBus() |
protected Scope |
getScope()
Returns the scope of this connector.
|
URI |
getTransportUri()
Return the URI describing this connector.
|
boolean |
isActive()
Tells whether this class is currently active or not.
|
void |
push(Event event)
Synchronously sends and event over the transport.
|
void |
setQualityOfServiceSpec(QualityOfServiceSpec spec)
Sets the quality of service requirements on sending and receiving event
notifications.
|
void |
setScope(Scope scope)
Sets the scope this connector is working on.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setQualityOfServiceSpec, setScope
activate, deactivate, isActive
public OutConnector(Bus bus)
bus
- the bus to use for sending events.public void push(Event event) throws RSBException
OutConnector
push
in interface OutConnector
event
- the event to sendRSBException
- error while sendingpublic URI getTransportUri()
Connector
getTransportUri
in interface Connector
null
protected Bus getBus()
protected Scope getScope()
null
if not yet setpublic void setQualityOfServiceSpec(QualityOfServiceSpec spec)
Connector
setQualityOfServiceSpec
in interface Connector
spec
- new spec to applypublic void setScope(Scope scope)
Connector
Activatable.activate()
method of the connector is called.public void activate() throws RSBException
Activatable
activate
in interface Activatable
RSBException
- generic error related to RSBpublic void deactivate() throws RSBException, InterruptedException
Activatable
deactivate
in interface Activatable
RSBException
- generic error related to RSBInterruptedException
- interrupted while waiting for proper deactivation. Object
might be in an undefined state nowpublic boolean isActive()
Activatable
isActive
in interface Activatable
true
if activeCopyright © 2018 CoR-Lab. All rights reserved.