Package | Description |
---|---|
rsb.protocol |
Contains classes dealing with the internal protocol of RSB used for sending
and receiving events.
|
rsb.protocol.collections | |
rsb.transport.socket |
Contains the implementation of the TCP socket transport.
|
rsb.transport.spread |
Contains the implementation of the spread-based transport.
|
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<NotificationType.Notification> |
NotificationType.Notification.PARSER |
Modifier and Type | Method and Description |
---|---|
NotificationType.Notification |
NotificationType.Notification.Builder.build() |
NotificationType.Notification |
NotificationType.Notification.Builder.buildPartial() |
static NotificationType.Notification |
NotificationType.Notification.getDefaultInstance() |
NotificationType.Notification |
NotificationType.Notification.getDefaultInstanceForType() |
NotificationType.Notification |
NotificationType.Notification.Builder.getDefaultInstanceForType() |
NotificationType.Notification |
FragmentedNotificationType.FragmentedNotificationOrBuilder.getNotification()
required .rsb.protocol.Notification notification = 1; |
NotificationType.Notification |
FragmentedNotificationType.FragmentedNotification.getNotification()
required .rsb.protocol.Notification notification = 1; |
NotificationType.Notification |
FragmentedNotificationType.FragmentedNotification.Builder.getNotification()
required .rsb.protocol.Notification notification = 1; |
static NotificationType.Notification |
NotificationType.Notification.parseDelimitedFrom(InputStream input) |
static NotificationType.Notification |
NotificationType.Notification.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static NotificationType.Notification |
NotificationType.Notification.parseFrom(byte[] data) |
static NotificationType.Notification |
NotificationType.Notification.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static NotificationType.Notification |
NotificationType.Notification.parseFrom(com.google.protobuf.ByteString data) |
static NotificationType.Notification |
NotificationType.Notification.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static NotificationType.Notification |
NotificationType.Notification.parseFrom(com.google.protobuf.CodedInputStream input) |
static NotificationType.Notification |
NotificationType.Notification.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static NotificationType.Notification |
NotificationType.Notification.parseFrom(InputStream input) |
static NotificationType.Notification |
NotificationType.Notification.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<NotificationType.Notification> |
NotificationType.Notification.getParserForType() |
Modifier and Type | Method and Description |
---|---|
static Event |
ProtocolConversion.fromNotification(NotificationType.Notification notification)
Build event from RSB Notification.
|
static Event |
ProtocolConversion.fromNotification(NotificationType.Notification notification,
ByteBuffer serializedData,
ConverterSelectionStrategy<ByteBuffer> converters)
Builds an
Event instance from a
NotificationType.Notification and a
ByteBuffer containing the event payload. |
NotificationType.Notification.Builder |
NotificationType.Notification.Builder.mergeFrom(NotificationType.Notification other) |
FragmentedNotificationType.FragmentedNotification.Builder |
FragmentedNotificationType.FragmentedNotification.Builder.mergeNotification(NotificationType.Notification value)
required .rsb.protocol.Notification notification = 1; |
static NotificationType.Notification.Builder |
NotificationType.Notification.newBuilder(NotificationType.Notification prototype) |
FragmentedNotificationType.FragmentedNotification.Builder |
FragmentedNotificationType.FragmentedNotification.Builder.setNotification(NotificationType.Notification value)
required .rsb.protocol.Notification notification = 1; |
Modifier and Type | Method and Description |
---|---|
NotificationType.Notification |
EventsByScopeMapType.EventsByScopeMap.ScopeSetOrBuilder.getNotifications(int index)
repeated .rsb.protocol.Notification notifications = 2; |
NotificationType.Notification |
EventsByScopeMapType.EventsByScopeMap.ScopeSet.getNotifications(int index)
repeated .rsb.protocol.Notification notifications = 2; |
NotificationType.Notification |
EventsByScopeMapType.EventsByScopeMap.ScopeSet.Builder.getNotifications(int index)
repeated .rsb.protocol.Notification notifications = 2; |
Modifier and Type | Method and Description |
---|---|
List<NotificationType.Notification> |
EventsByScopeMapType.EventsByScopeMap.ScopeSetOrBuilder.getNotificationsList()
repeated .rsb.protocol.Notification notifications = 2; |
List<NotificationType.Notification> |
EventsByScopeMapType.EventsByScopeMap.ScopeSet.getNotificationsList()
repeated .rsb.protocol.Notification notifications = 2; |
List<NotificationType.Notification> |
EventsByScopeMapType.EventsByScopeMap.ScopeSet.Builder.getNotificationsList()
repeated .rsb.protocol.Notification notifications = 2; |
Modifier and Type | Method and Description |
---|---|
EventsByScopeMapType.EventsByScopeMap.ScopeSet.Builder |
EventsByScopeMapType.EventsByScopeMap.ScopeSet.Builder.addNotifications(int index,
NotificationType.Notification value)
repeated .rsb.protocol.Notification notifications = 2; |
EventsByScopeMapType.EventsByScopeMap.ScopeSet.Builder |
EventsByScopeMapType.EventsByScopeMap.ScopeSet.Builder.addNotifications(NotificationType.Notification value)
repeated .rsb.protocol.Notification notifications = 2; |
EventsByScopeMapType.EventsByScopeMap.ScopeSet.Builder |
EventsByScopeMapType.EventsByScopeMap.ScopeSet.Builder.setNotifications(int index,
NotificationType.Notification value)
repeated .rsb.protocol.Notification notifications = 2; |
Modifier and Type | Method and Description |
---|---|
EventsByScopeMapType.EventsByScopeMap.ScopeSet.Builder |
EventsByScopeMapType.EventsByScopeMap.ScopeSet.Builder.addAllNotifications(Iterable<? extends NotificationType.Notification> values)
repeated .rsb.protocol.Notification notifications = 2; |
Modifier and Type | Method and Description |
---|---|
NotificationType.Notification |
BusConnection.readNotification()
Reads a notification from the connection.
|
NotificationType.Notification |
BusConnectionBase.readNotification() |
Modifier and Type | Method and Description |
---|---|
void |
SocketInPushConnector.handle(NotificationType.Notification notification) |
void |
Bus.NotificationReceiver.handle(NotificationType.Notification notification)
Callback method with the received notification.
|
protected void |
BusBase.handleGlobally(NotificationType.Notification notification)
Dispatches the notification to registered connections.
|
protected void |
BusBase.handleGlobally(NotificationType.Notification notification,
BusConnection ignoreConnection)
Dispatches the notification to registered connections.
|
void |
BusBase.handleIncoming(NotificationType.Notification notification)
Implement this method to specify the behavior in case of an incoming
notification received from a connection.
|
abstract void |
BusBase.handleIncoming(NotificationType.Notification notification,
BusConnection sourceConnection)
Implement this method to specify the behavior in case of an incoming
notification received from a connection.
|
void |
BusServer.handleIncoming(NotificationType.Notification notification,
BusConnection sourceConnection) |
void |
BusClient.handleIncoming(NotificationType.Notification notification,
BusConnection source) |
protected void |
BusBase.handleLocally(NotificationType.Notification notification)
Dispatches the specified notifications to all registered
Bus.NotificationReceiver s. |
void |
RefCountingBus.handleOutgoing(NotificationType.Notification notification) |
void |
BusBase.handleOutgoing(NotificationType.Notification notification) |
void |
Bus.handleOutgoing(NotificationType.Notification notification)
Handles a notification to be sent over the bus.
|
void |
BusConnection.sendNotification(NotificationType.Notification notification)
Sends a notification over the connection.
|
void |
BusConnectionBase.sendNotification(NotificationType.Notification notification) |
Modifier and Type | Method and Description |
---|---|
NotificationType.Notification |
AssemblyPool.DataAndNotification.getNotification()
Returns the causing notification for the data.
|
Constructor and Description |
---|
AssemblyPool.DataAndNotification(ByteBuffer data,
NotificationType.Notification notification)
Constructor.
|
Copyright © 2018 CoR-Lab. All rights reserved.