public class OutConnector extends AbstractConnector 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.
|
close
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
spec
- new spec to applypublic void setScope(Scope scope)
Connector
Activatable.activate()
method of the connector is called.scope
- the scopepublic void activate() throws RSBException
Activatable
RSBException
- generic error related to RSBpublic void deactivate() throws RSBException, InterruptedException
Activatable
RSBException
- generic error related to RSBInterruptedException
- interrupted while waiting for proper deactivation. Object
might be in an undefined state nowpublic boolean isActive()
Activatable
true
if activeCopyright © 2018 CoR-Lab. All rights reserved.