Modifier and Type | Method and Description |
---|---|
void |
BusMonitor.notifyInBusMessage(Message message) |
void |
BusMonitor.notifyIncomingMessageFromRemote(String queueId,
Message message) |
void |
BusMonitor.notifyMessageDeliveryFailure(String queueId,
Message mesage,
Throwable error) |
void |
BusMonitor.notifyOutgoingMessageToRemote(String queueId,
Message message) |
void |
ClientMessageBus.sendLocal(Message message)
Delivers the given message to all local callbacks that subscribe to its
subject.
|
Modifier and Type | Class and Description |
---|---|
class |
CommandMessage
The default implementation of the Message interface.
|
class |
ConversationMessage
A message that is automatically routed back to the originating bus of a
reference message (usually called the incoming message).
|
Modifier and Type | Method and Description |
---|---|
Message |
CommandMessage.addAllParts(Map<String,Object> parts) |
Message |
CommandMessage.addAllProvidedParts(Map<String,ResourceProvider<?>> parts) |
Message |
CommandMessage.command(Enum<?> type) |
Message |
CommandMessage.command(String type) |
Message |
CommandMessage.copy(Enum<?> part,
Message message) |
Message |
CommandMessage.copy(String part,
Message message) |
Message |
CommandMessage.copyResource(String key,
Message copyFrom) |
Message |
CommandMessage.errorsCall(ErrorCallback callback) |
Message |
CommandMessage.set(Enum<?> part,
Object value) |
Message |
CommandMessage.set(String part,
Object value) |
Message |
CommandMessage.setFlag(RoutingFlag flag) |
Message |
CommandMessage.setParts(Map<String,Object> parts) |
Message |
CommandMessage.setProvidedPart(Enum<?> part,
ResourceProvider<?> provider) |
Message |
CommandMessage.setProvidedPart(String part,
ResourceProvider<?> provider) |
Message |
CommandMessage.setResource(String key,
Object res) |
Message |
CommandMessage.toSubject(String subject) |
Modifier and Type | Method and Description |
---|---|
void |
ServiceCanceller.callback(Message message) |
Message |
CommandMessage.copy(Enum<?> part,
Message message) |
Message |
CommandMessage.copy(String part,
Message message) |
Message |
CommandMessage.copyResource(String key,
Message copyFrom) |
static ConversationMessage |
ConversationMessage.create(Enum<?> commandType,
Message inReplyTo)
Creates a new ConversationMessage with the specified command type and
reference message.
|
static ConversationMessage |
ConversationMessage.create(Message inReplyTo)
Creates a new ConversationMessage using an incoming message as a reference.
|
static ConversationMessage |
ConversationMessage.create(String commandType,
Message inReplyTo)
Creates a new ConversationMessage with the specified command type and
reference message.
|
static MessageBuildSubject<MessageReplySendable> |
MessageBuilder.createConversation(Message message)
Creates a conversational message.
|
static MessageBuildCommand<MessageReplySendable> |
MessageBuilder.createConversation(Message message,
String subject)
Creates a conversational message for the provided subject.
|
boolean |
DefaultErrorCallback.error(Message message,
Throwable e)
Constructs an error message and puts it on the client message bus with the subject
DefaultErrorCallback.CLIENT_ERROR_SUBJECT . |
boolean |
AsyncDelegateErrorCallback.error(Message message,
Throwable throwable)
Cancels future executions of the task by calling
AsyncTask.cancel(boolean) on the AsyncTask that controls its execution. |
Modifier and Type | Method and Description |
---|---|
Message |
MessageBuild.getMessage()
Gets the message created.
|
Message |
Sendable.getMessage() |
Modifier and Type | Method and Description |
---|---|
MessageBuildParms<R> |
MessageBuildParms.copy(Enum<?> part,
Message m)
Copies a message part to the specified message, replacing that part in the target message if it already exists.
|
MessageBuildParms<R> |
MessageBuildParms.copy(String part,
Message m)
Copies the message part to the specified message
|
MessageBuildParms<R> |
MessageBuildParms.copyResource(String part,
Message m)
Copies a message resource to the specified message, replacing that resource in the target message if it already exists.
|
Constructor and Description |
---|
DefaultRemoteCallBuilder(Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
Message.addAllParts(Map<String,Object> parts)
Copies in a set of message parts from the provided map.
|
Message |
Message.addAllProvidedParts(Map<String,ResourceProvider<?>> provided)
Copies in a set of provided message parts from the provided maps
|
Message |
Message.command(Enum<?> type)
Set the command type for this message.
|
Message |
Message.command(String type)
Sets the command type for this message.
|
Message |
Message.copy(Enum<?> part,
Message m)
Copies a part of this message to another message.
|
Message |
Message.copy(String part,
Message m)
Copies a part of this message to another message.
|
Message |
Message.copyResource(String key,
Message m)
Copies a transient resource to this message from the specified message.
|
Message |
Message.errorsCall(ErrorCallback callback)
Sets the error callback for this message.
|
Message |
MessageProvider.get()
Gets the appropriate message
|
Message |
Message.set(Enum<?> part,
Object value)
Sets a Message part to the specified value.
|
Message |
Message.set(String part,
Object value)
Sets a Message part to the specified value.
|
Message |
Message.setFlag(RoutingFlag flag)
Sets the provided flag for this message.
|
Message |
Message.setParts(Map<String,Object> parts)
Sets the message to contain the specified parts.
|
Message |
Message.setProvidedPart(Enum<?> part,
ResourceProvider<?> provider)
Adds or replaces a message part whose value is recomputed every time the message is sent.
|
Message |
Message.setProvidedPart(String part,
ResourceProvider<?> provider)
Adds or replaces a message part whose value is recomputed every time the message is sent.
|
Message |
Message.setResource(String key,
Object res)
Sets a transient resource.
|
Message |
Message.toSubject(String subject)
Sets the subject of this message, which is the intended recipient, and returns the message.
|
Modifier and Type | Method and Description |
---|---|
ErrorCallback<Message> |
Message.getErrorCallback()
Gets the error callback for this message.
|
Modifier and Type | Method and Description |
---|---|
void |
MessageCallback.callback(Message message)
Called by the Message Bus every time it processes a message with the
subject this callback is registered for.
|
Message |
Message.copy(Enum<?> part,
Message m)
Copies a part of this message to another message.
|
Message |
Message.copy(String part,
Message m)
Copies a part of this message to another message.
|
Message |
Message.copyResource(String key,
Message m)
Copies a transient resource to this message from the specified message.
|
void |
RequestDispatcher.dispatch(Message message)
Dispatches a message to a single receiver on the bus
|
void |
RequestDispatcher.dispatchGlobal(Message message)
Dispatches a message to all global listeners on the bus
|
boolean |
MessageListener.handleMessage(Message message)
Called by the Message Bus before the given message is routed to any
MessageListeners.
|
void |
MessageBus.send(Message message)
Transmits a message.
|
void |
MessageBus.send(Message message,
boolean fireListeners)
Transmits a message and may optionally supress message listeners from firing.
|
void |
MessageBus.sendGlobal(Message message)
Transmits the message to all directly-peered buses (global in relation to this bus only).
|
Modifier and Type | Method and Description |
---|---|
boolean |
ClientMessageBusImpl.callErrorHandler(Message message,
Throwable t) |
void |
ClientMessageBusImpl.encodeAndTransmit(Message message) |
void |
ClientMessageBusImpl.send(Message message)
Sends the message using it's encoded subject.
|
void |
ClientMessageBusImpl.send(Message message,
boolean fireListeners)
Sends the specified message, and notifies the listeners.
|
void |
ClientMessageBusImpl.sendGlobal(Message message)
Globally send message to all receivers.
|
void |
ClientMessageBusImpl.sendLocal(Message msg) |
Modifier and Type | Method and Description |
---|---|
Collection<Message> |
SSEHandler.stop(boolean stopAllCurrentRequests) |
Collection<Message> |
HttpPollingHandler.stop(boolean stopAllCurrentRequests) |
Collection<Message> |
WebsocketHandler.stop(boolean stopAllCurrentRequests) |
Collection<Message> |
TransportHandler.stop(boolean stopAllCurrentRequests)
Called to stop the transport.
|
Modifier and Type | Method and Description |
---|---|
void |
SSEHandler.configure(Message capabilitiesMessage) |
void |
HttpPollingHandler.configure(Message capabilitiesMessage) |
void |
WebsocketHandler.configure(Message capabilitiesMessage) |
void |
TransportHandler.configure(Message capabilitiesMessage)
Called to configure the transport.
|
void |
SSEHandler.handleProtocolExtension(Message message) |
void |
HttpPollingHandler.handleProtocolExtension(Message message) |
void |
WebsocketHandler.handleProtocolExtension(Message message) |
void |
TransportHandler.handleProtocolExtension(Message message)
Allows extension to the standard ErraiBus Protocol by optionally handling any unknown protocol verbs from the
wire.
|
Modifier and Type | Method and Description |
---|---|
void |
SSEHandler.transmit(List<Message> txMessages) |
void |
HttpPollingHandler.transmit(List<Message> txMessages) |
void |
WebsocketHandler.transmit(List<Message> txMessages) |
void |
TransportHandler.transmit(List<Message> txMessages)
Transmits the specified list of
Message to the remote bus over the transport. |
Modifier and Type | Method and Description |
---|---|
static Message |
BusToolsCli.decodeCommandMessage(EJValue value) |
Modifier and Type | Method and Description |
---|---|
static List<Message> |
BusToolsCli.decodePayload(String jsonString) |
Modifier and Type | Method and Description |
---|---|
static void |
ErrorHelper.disconnectRemoteBus(MessageBus bus,
Message message)
Sends a disconnect command message to the client bus
|
static String |
BusToolsCli.encodeMessage(Message message) |
static String |
SimpleMessage.get(Message message) |
static void |
ErrorHelper.handleMessageDeliveryFailure(MessageBus bus,
Message message,
String errorMessage,
Throwable e,
boolean disconnect)
Handles the failed delivery of a message, and sends the error to the appropriate place
|
static void |
SimpleMessage.send(Message message,
String msgText) |
static void |
ErrorHelper.sendClientError(MessageBus bus,
Message message,
String errorMessage,
String additionalDetails)
Sends the error message via conversation to the ClientBusErrors subject
|
static void |
ErrorHelper.sendClientError(MessageBus bus,
Message message,
String errorMessage,
Throwable e)
Creates the stacktrace for the error message and sends it via conversation to the
ClientBusErrors subject
|
Modifier and Type | Method and Description |
---|---|
static String |
BusToolsCli.encodeMessages(Collection<Message> messages) |
Modifier and Type | Method and Description |
---|---|
Message |
ServerMessageBusImpl.getDeadLetterMessage(String messageId) |
Message |
ClusterWaitEntry.getMessage() |
Modifier and Type | Method and Description |
---|---|
protected BlockingQueue<Message> |
WorkerFactory.getMessages()
Gets the messages in the queue
|
Modifier and Type | Method and Description |
---|---|
void |
ServerMessageBusImpl.RemoteMessageCallback.callback(Message message) |
void |
DeliveryPlan.deliver(Message m) |
void |
WorkerFactory.deliver(Message m)
Attempts to send the message
|
void |
WorkerFactory.deliverGlobal(Message m)
Attempts to deliver the specified message globally
|
static void |
Worker.deliverToBus(MessageBus bus,
Message message) |
void |
SimpleDispatcher.dispatch(Message message) |
void |
AsyncDispatcher.dispatch(Message message) |
void |
SimpleDispatcher.dispatchGlobal(Message message) |
void |
AsyncDispatcher.dispatchGlobal(Message message)
Sends the message globally.
|
boolean |
MessageQueueImpl.offer(Message message)
Inserts the specified message into the queue, and returns true if it was successful
|
void |
ServerMessageBusImpl.send(Message message)
Sends the message
|
void |
ServerMessageBusImpl.send(Message message,
boolean fireListeners)
Parses the message appropriately and enqueues it for delivery
|
void |
ServerMessageBusImpl.sendGlobal(Message message)
Sends a message globally to all subscriptions containing the same subject as the specified message.
|
Constructor and Description |
---|
ClusterWaitEntry(long time,
Message message,
Runnable timeoutCallback) |
Modifier and Type | Method and Description |
---|---|
Message |
ServerMessageBus.getDeadLetterMessage(String messageId) |
static Message |
RpcContext.getMessage() |
Modifier and Type | Method and Description |
---|---|
boolean |
MessageQueue.offer(Message message) |
static void |
RpcContext.set(Message message)
Reads resources from the provided
Message and stores them in ThreadLocal s. |
Modifier and Type | Method and Description |
---|---|
void |
ClusteringProvider.clusterTransmitGlobal(Message message)
Advertises a global message to the entire cluster.
|
Modifier and Type | Method and Description |
---|---|
static Message |
JGroupsClusteringProvider.getErraiMessage(org.jgroups.Message message) |
Modifier and Type | Method and Description |
---|---|
void |
JGroupsClusteringProvider.callback(Message message) |
void |
JGroupsClusteringProvider.clusterTransmitGlobal(Message message) |
Modifier and Type | Method and Description |
---|---|
void |
NoopClusteringProvider.clusterTransmitGlobal(Message message) |
Modifier and Type | Method and Description |
---|---|
static Message |
MessageFactory.createCommandMessage(QueueSession session,
javax.servlet.http.HttpServletRequest request,
String json)
Creates the command message from the given JSON string and session.
|
static Message |
MessageFactory.createCommandMessage(QueueSession session,
String json) |
Modifier and Type | Method and Description |
---|---|
static List<Message> |
MessageFactory.createCommandMessage(QueueSession session,
EJValue value) |
static List<Message> |
MessageFactory.createCommandMessage(QueueSession session,
javax.servlet.http.HttpServletRequest request) |
static List<Message> |
MessageFactory.createCommandMessage(QueueSession session,
InputStream inputStream) |
Modifier and Type | Method and Description |
---|---|
void |
EndpointCallback.callback(Message message)
Invokes the endpoint function based on the details of the message
|
void |
RemoteServiceCallback.callback(Message message)
Invokes all callback functions that can be associated to the message
|
void |
ServiceMethodCallback.callback(Message message) |
void |
VoidRPCEndpointCallback.callback(Message message) |
void |
ValueReplyRPCEndpointCallback.callback(Message message) |
void |
AsyncRPCEndpointCallback.callback(Message message) |
void |
CommandBindingsCallback.callback(Message message) |
boolean |
DirectDeliveryHandler.deliver(MessageQueue queue,
Message message) |
boolean |
BufferDeliveryHandler.deliver(MessageQueue queue,
Message message) |
boolean |
MessageDeliveryHandler.deliver(MessageQueue queue,
Message message)
This method is responsible for delivering a message into the transport layer.
|
static void |
BufferHelper.encodeAndWrite(Buffer buffer,
BufferColor bufferColor,
Message message) |
Object |
ServiceInstanceProvider.get(Message message) |
Object |
AbstractRPCMethodCallback.invokeMethodFromMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
MessageBusProxy.getDeadLetterMessage(String messageId) |
Modifier and Type | Method and Description |
---|---|
void |
RequestDispatcherProxy.dispatch(Message message) |
void |
RequestDispatcherProxy.dispatchGlobal(Message message) |
void |
MessageBusProxy.send(Message message) |
void |
MessageBusProxy.send(Message message,
boolean fireListeners) |
void |
MessageBusProxy.sendGlobal(Message message) |
void |
ErraiServiceImpl.store(Message message)
Passes off the message to the bus for handling
|
void |
ErraiService.store(Message message)
Stores the specified message
|
Modifier and Type | Method and Description |
---|---|
void |
ErraiServiceImpl.store(Collection<Message> messages) |
void |
ErraiService.store(Collection<Message> messages)
Stores a collection of messages/
|
Modifier and Type | Method and Description |
---|---|
static SessionContext |
SessionContext.get(Message message) |
static ServerLaundryList |
ServerLaundryList.get(Message message) |
static LocalContext |
LocalContext.get(Message message) |
Modifier and Type | Method and Description |
---|---|
static QueueSession |
CDIServerUtil.getSession(Message message) |
Modifier and Type | Method and Description |
---|---|
static void |
EventConversationContext.activate(Message message)
Convenience method to active the conversation scope from a Errai
Message object, by extracting the
session ID referenced within. |
void |
EventDispatcher.callback(Message message) |
boolean |
EventDispatcher.isRoutable(LocalContext localContext,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractCDIEventCallback.callback(Message message) |
Modifier and Type | Method and Description |
---|---|
static void |
CDI.consumeEventFromMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
void |
EntitySyncCallback.callback(Message message) |
Modifier and Type | Method and Description |
---|---|
static Message |
UiHelper.decodeAndDemarshall(String json) |
static Message |
UiHelper.uglyReEncode(String message) |
Modifier and Type | Method and Description |
---|---|
void |
ClientBusProxyImpl.conversationWith(Message message,
MessageCallback callback) |
void |
ActivityProcessor.notifyEvent(long time,
EventType type,
SubEventType subType,
String fromBus,
String toBus,
String subject,
Message message,
Throwable error,
boolean replay) |
void |
ServiceActivityMonitor.notifyMessage(long time,
Message message) |
void |
ClientBusProxyImpl.send(Message message) |
void |
ClientBusProxyImpl.send(Message message,
boolean fireListeners) |
void |
ClientBusProxyImpl.sendGlobal(Message message) |
void |
Dataservice.storeRecord(long time,
String fromBus,
String toBus,
String service,
Message message) |
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.