- call() - Method in class rsb.eventprocessing.MatchAndDispatchTask
-
- call(U) - Method in class rsb.patterns.AbstractRemoteMethod
-
- call(U) - Method in class rsb.patterns.RemoteDataMethod
-
- call(Event) - Method in class rsb.patterns.RemoteEventMethod
-
- call(String, Event) - Method in class rsb.patterns.RemoteServer
-
- call(String, T) - Method in class rsb.patterns.RemoteServer
-
Blocking call directly returning the data or throwing an
exception upon timeout, interruption or failure.
- callAsync(String, Event) - Method in class rsb.patterns.RemoteServer
-
- callAsync(String, U) - Method in class rsb.patterns.RemoteServer
-
Async call returning an rsb.patterns.Future object
- cancel(boolean) - Method in class rsb.patterns.Future
-
This method makes the waiting thread return with a
CancellationException but does not cancel the actual
operation the thread was waiting for.
- cancelled - Variable in class rsb.patterns.Future
-
- checkConnection() - Method in class rsb.transport.spread.SpreadWrapper
-
- clearObservers() - Method in class rsb.filter.FilterObservable
-
- complete(T) - Method in class rsb.patterns.Future
-
- completeRequest(Future<T>, Event) - Method in class rsb.patterns.AbstractRemoteMethod
-
- completeRequest(Future<T>, Event) - Method in class rsb.patterns.RemoteDataMethod
-
- completeRequest(Future<Event>, Event) - Method in class rsb.patterns.RemoteEventMethod
-
- concat(Scope) - Method in class rsb.Scope
-
Creates a new scope that is a sub-scope of this one with the subordinated
scope described by the given argument.
- config - Variable in class rsb.transport.Router
-
- connect() - Method in class rsb.transport.socket.BusConnection
-
Perform simple handshake as specified in RSB socket protocol.
- ConnectionLostException - Exception in rsb.transport.spread
-
- ConnectionLostException(String) - Constructor for exception rsb.transport.spread.ConnectionLostException
-
- ConversionException - Exception in rsb.converter
-
An exception that indicates a conversion error in a
Converter
.
- ConversionException(String) - Constructor for exception rsb.converter.ConversionException
-
Constructor with a message.
- ConversionException(Throwable) - Constructor for exception rsb.converter.ConversionException
-
Constructor with a root cause.
- ConversionException(String, Throwable) - Constructor for exception rsb.converter.ConversionException
-
Constructor with message and root cause.
- Converter<WireType> - Interface in rsb.converter
-
This class represents a converter interface for a wire format T.
- converter - Variable in class rsb.Informer
-
converter repository for type mappings
- ConverterRepository<WireType> - Interface in rsb.converter
-
Maintains a collection of converters for a specific wire format.
- ConverterSelectionStrategy<WireType> - Interface in rsb.converter
-
Implementation of this interface perform mappings of one of the
followings forms:
- wire-schema -> @ref Converter
- data-type -> @ref Converter
- ConverterSignature - Class in rsb.converter
-
Immutable object representing a converter signature.
- ConverterSignature(String, Class<?>) - Constructor for class rsb.converter.ConverterSignature
-
- createInformer(Scope, Class<?>) - Method in class rsb.Factory
-
Creates a new informer instance.
- createInformer(String, Class<?>) - Method in class rsb.Factory
-
Creates a new informer instance.
- createInformer(Scope) - Method in class rsb.Factory
-
Creates a new informer instance.
- createInformer(String) - Method in class rsb.Factory
-
Creates a new informer instance.
- createListener(Scope) - Method in class rsb.Factory
-
Creates a new listener instance.
- createListener(String) - Method in class rsb.Factory
-
Creates a new listener instance.
- createLocalServer(Scope) - Method in class rsb.Factory
-
Creates a new LocalServer object which exposes methods under the scope @a
scope.
- createLocalServer(String) - Method in class rsb.Factory
-
Creates a new LocalServer object which exposes methods under the scope @a
scope.
- createPort(EventHandler) - Method in class rsb.transport.spread.SpreadFactory
-
- createPort() - Method in class rsb.transport.TransportFactory
-
- createPort(EventHandler) - Method in class rsb.transport.TransportFactory
-
- createRemoteServer(Scope) - Method in class rsb.Factory
-
Creates a new RemoteServer object which is suitable for calling methods
provided by a remote server under the scope @a scope.
- createRemoteServer(String) - Method in class rsb.Factory
-
Creates a new RemoteServer object which is suitable for calling methods
provided by a remote server under the scope @a scope.
- createRemoteServer(Scope, double) - Method in class rsb.Factory
-
Creates a new RemoteServer object which is suitable for calling methods
provided by a remote server under the scope @a scope.
- createRemoteServer(String, double) - Method in class rsb.Factory
-
Creates a new RemoteServer object which is suitable for calling methods
provided by a remote server under the scope @a scope.
- ctx - Variable in class rsb.InformerState
-
- get() - Method in class rsb.patterns.Future
-
Convenience method for get(0, TimeUnit.MILLISECONDS).
- get(long) - Method in class rsb.patterns.Future
-
Convenience method for get(timeout, TimeUnit.MILLISECONDS).
- get(long, TimeUnit) - Method in class rsb.patterns.Future
-
Gets the results passed to this callback object.
- get() - Method in class rsb.transport.SequenceNumber
-
- getAsUUID() - Method in class rsb.EventId
-
- getCauses() - Method in class rsb.Event
-
Returns all causing events marked so far.
- getComponents() - Method in class rsb.Scope
-
Returns all components of the scope as an ordered list.
- getConverter(String) - Method in interface rsb.converter.ConverterSelectionStrategy
-
Tries to look up the converter designated by @a key.
- getConverter(String) - Method in class rsb.converter.UnambiguousConverterMap
-
- getConverterMap() - Method in class rsb.converter.DefaultConverterRepository
-
- getConverters() - Method in class rsb.config.Transport
-
- getConvertersForDeserialization() - Method in interface rsb.converter.ConverterRepository
-
- getConvertersForDeserialization() - Method in class rsb.converter.DefaultConverterRepository
-
- getConvertersForSerialization() - Method in interface rsb.converter.ConverterRepository
-
This method queries the converter map for seralizable data types and
returns an UnambiguousConverterMap for the chosen to the
caller.
- getConvertersForSerialization() - Method in class rsb.converter.DefaultConverterRepository
-
- getCreateTime() - Method in class rsb.MetaData
-
Returns a time stamp that is automatically filled with the time the event
instance was created by the language binding.
- getData() - Method in class rsb.converter.UserData
-
Returns the deserialized data.
- getData() - Method in class rsb.Event
-
- getData() - Method in class rsb.transport.spread.AssemblyPool.DataAndNotification
-
- getData() - Method in class rsb.transport.spread.DataMessage
-
- getDatatype() - Method in class rsb.converter.ConverterSignature
-
- getDefaultConverterRepository() - Static method in class rsb.converter.DefaultConverterRepository
-
- getDeliverTime() - Method in class rsb.MetaData
-
Returns the time at which an event was decoded and will be dispatched to
the client as soon as possible (set directly before passing it to the
client handler).
- getFilterIterator() - Method in class rsb.Listener
-
- getFilters() - Method in class rsb.Listener
-
- getGroups() - Method in class rsb.transport.spread.DataMessage
-
- getHandlerIterator() - Method in class rsb.Listener
-
- getHandlers() - Method in class rsb.Listener
-
- getId() - Method in class rsb.Event
-
- getId() - Method in class rsb.Participant
-
Returns the unique ID of this participant.
- getInformer() - Method in class rsb.patterns.Method
-
Return the Informer object associated to this method.
- getInstance() - Static method in class rsb.Factory
-
Returns the one and only instance of this class.
- getInstance() - Static method in class rsb.transport.TransportFactory
-
- getInstance() - Static method in class rsb.util.Properties
-
- getListener() - Method in class rsb.patterns.Method
-
Return the Listener object associated to this method.
- getMetaData() - Method in class rsb.Event
-
Returns a
MetaData
instance representing the meta data for this
event.
- getMethod() - Method in class rsb.Event
-
- getMethods() - Method in class rsb.patterns.Server
-
Return all methods of the server.
- getName() - Method in class rsb.patterns.Method
-
Return the name of this method.
- getNameBasedUUID(UUID, String) - Static method in class rsb.util.UUIDTools
-
Generates name-based URIs according to Version 5 (SHA-1).
- getNotification() - Method in class rsb.transport.spread.AssemblyPool.DataAndNotification
-
- getOrdering() - Method in class rsb.QualityOfServiceSpec
-
Returns the desired ordering setting.
- getOrigin() - Method in class rsb.filter.OriginFilter
-
- getParticipantId() - Method in class rsb.EventId
-
Returns the id of the participant that sent the event.
- getPrivateGroup() - Method in class rsb.transport.spread.SpreadWrapper
-
- getProperty(String) - Method in class rsb.util.Properties
-
- getPropertyAsBool(String) - Method in class rsb.util.Properties
-
- getPropertyAsInt(String) - Method in class rsb.util.Properties
-
- getQueue() - Method in class rsb.util.QueueAdapter
-
- getReceiveTime() - Method in class rsb.MetaData
-
Returns the time at which an event is received by listener in its encoded
form.
- getReliability() - Method in class rsb.QualityOfServiceSpec
-
Returns the desired reliability setting.
- getRouter() - Method in class rsb.Participant
-
Returns the router used for this participant.
- getSchema() - Method in class rsb.converter.ConverterSignature
-
- getScope() - Method in class rsb.Event
-
- getScope() - Method in class rsb.filter.ScopeFilter
-
- getScope() - Method in class rsb.Participant
-
Returns the scope of this participant.
- getSenderId() - Method in class rsb.Event
-
- getSendTime() - Method in class rsb.MetaData
-
Returns the time at which the generated notification for an event was
sent on the bus (after serialization).
- getSequenceNumber() - Method in class rsb.Event
-
- getSequenceNumber() - Method in class rsb.EventId
-
Returns the sequence number which makes this id unique combined with the
sending participants id.
- getSerialization() - Method in class rsb.converter.WireContents
-
Returns the contents for the wire in their serialized form.
- getServer() - Method in class rsb.patterns.Method
-
Return the Server object to which this method is associated.
- getSignature() - Method in interface rsb.converter.Converter
-
Get signature for this converter.
- getSignature() - Method in class rsb.converter.EventIdConverter
-
- getSignature() - Method in class rsb.converter.NullConverter
-
- getSignature() - Method in class rsb.converter.ProtocolBufferConverter
-
- getSignature() - Method in class rsb.converter.StringConverter
-
- getSignature() - Method in class rsb.converter.Uint64Converter
-
- getSpreadhost() - Method in class rsb.transport.spread.SpreadWrapper
-
- getSpreadMessage() - Method in class rsb.transport.spread.DataMessage
-
- getStatus() - Method in class rsb.transport.spread.SpreadWrapper
-
- getTimeout() - Method in class rsb.patterns.RemoteServer
-
- getTransportFactory() - Method in class rsb.Participant
-
- getType() - Method in class rsb.Event
-
- getType() - Method in interface rsb.transport.Port
-
- getType() - Method in class rsb.transport.spread.SpreadPort
-
- getTypeInfo() - Method in class rsb.converter.UserData
-
Class object describing the type of the deserialized data.
- getTypeInfo() - Method in class rsb.Informer
-
Returns the class describing the type of data sent by this informer.
- getUserInfo(String) - Method in class rsb.MetaData
-
Returns the user-defined string for the given key.
- getUserTime(String) - Method in class rsb.MetaData
-
Returns the user timestamp stored under the provided key.
- getUUID() - Method in class rsb.ParticipantId
-
- getWireSchema() - Method in class rsb.converter.WireContents
-
Returns the identifier of the wire schema that was used to serialize
the contents.
- s - Variable in class rsb.ListenerState
-
- Scope - Class in rsb
-
A scope defines a channel of the hierarchical unified bus covered by RSB.
- Scope(String) - Constructor for class rsb.Scope
-
Parses a scope from a string representation.
- ScopeFilter - Class in rsb.filter
-
- ScopeFilter(Scope) - Constructor for class rsb.filter.ScopeFilter
-
- send(Event) - Method in class rsb.Informer.InformerStateActive
-
- send(T) - Method in class rsb.Informer.InformerStateActive
-
- send(Event) - Method in class rsb.Informer
-
Send an
Event
to all subscribed participants.
- send(T) - Method in class rsb.Informer
-
Send data (of type ) to all subscribed participants.
- send(Event) - Method in class rsb.InformerState
-
- send(T) - Method in class rsb.InformerState
-
- send(DataMessage) - Method in class rsb.transport.spread.SpreadWrapper
-
- sendRequest(Event) - Method in class rsb.patterns.AbstractRemoteMethod
-
- sequenceNumber - Variable in class rsb.Informer
-
atomic uint32 counter object for event sequence numbers
- SequenceNumber - Class in rsb.transport
-
Atomic uint32 implementation respecting
size of ProtocolBuffer uint32 type.
- SequenceNumber() - Constructor for class rsb.transport.SequenceNumber
-
- SequenceNumber(long) - Constructor for class rsb.transport.SequenceNumber
-
- serialize(Class<?>, Object) - Method in interface rsb.converter.Converter
-
Serializes user data to a wire representation.
- serialize(Class<?>, Object) - Method in class rsb.converter.EventIdConverter
-
- serialize(Class<?>, Object) - Method in class rsb.converter.NullConverter
-
- serialize(Class<?>, Object) - Method in class rsb.converter.ProtocolBufferConverter
-
- serialize(Class<?>, Object) - Method in class rsb.converter.StringConverter
-
- serialize(Class<?>, Object) - Method in class rsb.converter.Uint64Converter
-
- SerializeException - Exception in rsb.transport.spread
-
- SerializeException(String) - Constructor for exception rsb.transport.spread.SerializeException
-
- Server - Class in rsb.patterns
-
Objects of this class represent local or remote serves.
- Server(Scope, TransportFactory, PortConfiguration) - Constructor for class rsb.patterns.Server
-
- Server(String, TransportFactory, PortConfiguration) - Constructor for class rsb.patterns.Server
-
- Server.ServerStateActive - Class in rsb.patterns
-
- Server.ServerStateActive(Server) - Constructor for class rsb.patterns.Server.ServerStateActive
-
- Server.ServerStateInactive - Class in rsb.patterns
-
- Server.ServerStateInactive(Server) - Constructor for class rsb.patterns.Server.ServerStateInactive
-
- setConnectionLost(boolean) - Method in class rsb.transport.spread.SpreadWrapper
-
- setCreateTime(long) - Method in class rsb.MetaData
-
Sets the time stamp that is automatically filled with the time the event
instance was created by the language binding.
- setData(Object) - Method in class rsb.Event
-
- setData(ByteBuffer) - Method in class rsb.transport.spread.DataMessage
-
- setData(byte[]) - Method in class rsb.transport.spread.DataMessage
-
- setDeliverTime(long) - Method in class rsb.MetaData
-
Sets the time at which an event was decoded and will be dispatched to the
client as soon as possible (set directly before passing it to the client
handler).
- setErrorHandler(ErrorHandler) - Method in class rsb.Listener
-
Deprecated.
not yet designed
- setGroups(String[]) - Method in class rsb.transport.spread.DataMessage
-
- setId(ParticipantId, long) - Method in class rsb.Event
-
Sets all information necessary to generate the
EventId
of this
event.
- setId(EventId) - Method in class rsb.Event
-
Sets the id of this event.
- setMethod(String) - Method in class rsb.Event
-
- setProperty(String, String) - Method in class rsb.util.Properties
-
- setQualityOfServiceSpec(QualityOfServiceSpec) - Method in interface rsb.transport.Port
-
Sets the quality of service requirements on sending and receiving event
notifications.
- setQualityOfServiceSpec(QualityOfServiceSpec) - Method in class rsb.transport.spread.SpreadPort
-
- setReceiveTime(long) - Method in class rsb.MetaData
-
Sets the time at which an event is received by listener in its encoded
form.
- setScope(Scope) - Method in class rsb.Event
-
- setScope(Scope) - Method in class rsb.filter.ScopeFilter
-
- setSendTime(long) - Method in class rsb.MetaData
-
Sets the time at which the generated notification for an event was sent
on the bus (after serialization).
- setStatus(SpreadWrapper.State) - Method in class rsb.transport.spread.SpreadWrapper
-
- setType(Class<?>) - Method in class rsb.Event
-
- setTypeInfo(Class<?>) - Method in class rsb.Informer
-
Set the class object describing the type of data sent by this informer.
- setUserInfo(String, String) - Method in class rsb.MetaData
-
Sets a user info with the specified key and value or replaces and already
existing one
- setUserTime(String, long) - Method in class rsb.MetaData
-
Sets a user timestamp and replaces existing entries.
- setUseTcpNoDelay(boolean) - Method in class rsb.transport.spread.SpreadWrapper
-
- shutdownAndWait() - Method in interface rsb.eventprocessing.EventReceivingStrategy
-
- shutdownAndWait() - Method in class rsb.eventprocessing.SingleThreadEventReceivingStrategy
-
- shutdownAndWait() - Method in class rsb.eventprocessing.UnorderedParallelEventReceivingStrategy
-
- SingleThreadEventReceivingStrategy - Class in rsb.eventprocessing
-
- SingleThreadEventReceivingStrategy() - Constructor for class rsb.eventprocessing.SingleThreadEventReceivingStrategy
-
- singleton - Static variable in class rsb.util.Properties
-
- skip(EventId) - Method in class rsb.filter.AbstractFilter
-
skip this filter for any event with the specified ID.
- skip(EventId) - Method in class rsb.filter.OriginFilter
-
- skip(EventId) - Method in class rsb.filter.ScopeFilter
-
- skip(EventId) - Method in class rsb.filter.TypeFilter
-
- skipped(EventId) - Method in class rsb.filter.AbstractFilter
-
remove ID from the list after the corresponding event has been skipped.
- SpreadFactory - Class in rsb.transport.spread
-
- SpreadFactory() - Constructor for class rsb.transport.spread.SpreadFactory
-
- SpreadPort - Class in rsb.transport.spread
-
A port which connects to a spread daemon network.
- SpreadPort(SpreadWrapper, EventHandler, ConverterSelectionStrategy<ByteBuffer>, ConverterSelectionStrategy<ByteBuffer>) - Constructor for class rsb.transport.spread.SpreadPort
-
- SpreadWrapper - Class in rsb.transport.spread
-
This class encapsulates and manages a connection to the spread daemon.
- SpreadWrapper() - Constructor for class rsb.transport.spread.SpreadWrapper
-
Create a new Manager, assuming a spread daemon on localhost, port 4803.
- SpreadWrapper(String, int) - Constructor for class rsb.transport.spread.SpreadWrapper
-
Create a new Manager using the specified connection data for the Spread
network.
- SpreadWrapper(String, int, boolean) - Constructor for class rsb.transport.spread.SpreadWrapper
-
- stamp - Variable in class rsb.util.Timestamp
-
- state - Variable in class rsb.Informer
-
state variable for publisher instance
- StringConverter - Class in rsb.converter
-
A converter with wire type ByteBuffer
that is capable of handling
strings with different encodings.
- StringConverter() - Constructor for class rsb.converter.StringConverter
-
Creates a converter for UTF-8 encoding with utf-8-string wire schema.
- StringConverter(String, String) - Constructor for class rsb.converter.StringConverter
-
Creates a converter that uses the specified encoding for strings.
- StringConverter(Charset, String) - Constructor for class rsb.converter.StringConverter
-
Creates a converter that uses the specified charset for strings.
- superScopes(boolean) - Method in class rsb.Scope
-
Generates all super scopes of this scope including the root scope "/".