|
Errai 3.0.1-SNAPSHOT | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Message in org.jboss.errai.bus.client.api |
---|
Methods in org.jboss.errai.bus.client.api with parameters of type Message | |
---|---|
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. |
Uses of Message in org.jboss.errai.bus.client.api.base |
---|
Classes in org.jboss.errai.bus.client.api.base that implement Message | |
---|---|
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). |
Methods in org.jboss.errai.bus.client.api.base that return Message | |
---|---|
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)
|
Methods in org.jboss.errai.bus.client.api.base with parameters of type Message | |
---|---|
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 |
AsyncDelegateErrorCallback.error(Message message,
Throwable throwable)
Cancels future executions of the task by calling AsyncTask.cancel(boolean) on the AsyncTask that controls its execution. |
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 . |
Uses of Message in org.jboss.errai.bus.client.api.builder |
---|
Methods in org.jboss.errai.bus.client.api.builder that return Message | |
---|---|
Message |
Sendable.getMessage()
|
Message |
MessageBuild.getMessage()
Gets the message created. |
Methods in org.jboss.errai.bus.client.api.builder with parameters of type Message | |
---|---|
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. |
Constructors in org.jboss.errai.bus.client.api.builder with parameters of type Message | |
---|---|
DefaultRemoteCallBuilder(Message message)
|
Uses of Message in org.jboss.errai.bus.client.api.messaging |
---|
Methods in org.jboss.errai.bus.client.api.messaging that return Message | |
---|---|
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. |
Methods in org.jboss.errai.bus.client.api.messaging that return types with arguments of type Message | |
---|---|
ErrorCallback<Message> |
Message.getErrorCallback()
Gets the error callback for this message. |
Methods in org.jboss.errai.bus.client.api.messaging with parameters of type Message | |
---|---|
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). |
Uses of Message in org.jboss.errai.bus.client.framework |
---|
Methods in org.jboss.errai.bus.client.framework with parameters of type Message | |
---|---|
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)
|
Uses of Message in org.jboss.errai.bus.client.framework.transports |
---|
Methods in org.jboss.errai.bus.client.framework.transports that return types with arguments of type Message | |
---|---|
Collection<Message> |
WebsocketHandler.stop(boolean stopAllCurrentRequests)
|
Collection<Message> |
SSEHandler.stop(boolean stopAllCurrentRequests)
|
Collection<Message> |
TransportHandler.stop(boolean stopAllCurrentRequests)
Called to stop the transport. |
Collection<Message> |
HttpPollingHandler.stop(boolean stopAllCurrentRequests)
|
Methods in org.jboss.errai.bus.client.framework.transports with parameters of type Message | |
---|---|
void |
WebsocketHandler.configure(Message capabilitiesMessage)
|
void |
SSEHandler.configure(Message capabilitiesMessage)
|
void |
TransportHandler.configure(Message capabilitiesMessage)
Called to configure the transport. |
void |
HttpPollingHandler.configure(Message capabilitiesMessage)
|
void |
WebsocketHandler.handleProtocolExtension(Message message)
|
void |
SSEHandler.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. |
void |
HttpPollingHandler.handleProtocolExtension(Message message)
|
Method parameters in org.jboss.errai.bus.client.framework.transports with type arguments of type Message | |
---|---|
void |
WebsocketHandler.transmit(List<Message> txMessages)
|
void |
SSEHandler.transmit(List<Message> txMessages)
|
void |
TransportHandler.transmit(List<Message> txMessages)
Transmits the specified list of Message to the remote bus over the transport. |
void |
HttpPollingHandler.transmit(List<Message> txMessages)
|
Uses of Message in org.jboss.errai.bus.client.util |
---|
Methods in org.jboss.errai.bus.client.util that return Message | |
---|---|
static Message |
BusToolsCli.decodeCommandMessage(EJValue value)
|
Methods in org.jboss.errai.bus.client.util that return types with arguments of type Message | |
---|---|
static List<Message> |
BusToolsCli.decodePayload(String jsonString)
|
Methods in org.jboss.errai.bus.client.util with parameters of type Message | |
---|---|
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 |
Method parameters in org.jboss.errai.bus.client.util with type arguments of type Message | |
---|---|
static String |
BusToolsCli.encodeMessages(Collection<Message> messages)
|
Uses of Message in org.jboss.errai.bus.server |
---|
Methods in org.jboss.errai.bus.server that return Message | |
---|---|
Message |
ServerMessageBusImpl.getDeadLetterMessage(String messageId)
|
Message |
ClusterWaitEntry.getMessage()
|
Methods in org.jboss.errai.bus.server that return types with arguments of type Message | |
---|---|
protected BlockingQueue<Message> |
WorkerFactory.getMessages()
Gets the messages in the queue |
Methods in org.jboss.errai.bus.server with parameters of type Message | |
---|---|
void |
ServerMessageBusImpl.RemoteMessageCallback.callback(Message message)
|
void |
WorkerFactory.deliver(Message m)
Attempts to send the message |
void |
DeliveryPlan.deliver(Message m)
|
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. |
Constructors in org.jboss.errai.bus.server with parameters of type Message | |
---|---|
ClusterWaitEntry(long time,
Message message,
Runnable timeoutCallback)
|
Uses of Message in org.jboss.errai.bus.server.api |
---|
Methods in org.jboss.errai.bus.server.api that return Message | |
---|---|
Message |
ServerMessageBus.getDeadLetterMessage(String messageId)
|
static Message |
RpcContext.getMessage()
|
Methods in org.jboss.errai.bus.server.api with parameters of type Message | |
---|---|
boolean |
MessageQueue.offer(Message message)
|
static void |
RpcContext.set(Message message)
Reads resources from the provided Message and stores them in ThreadLocal s. |
Uses of Message in org.jboss.errai.bus.server.cluster |
---|
Methods in org.jboss.errai.bus.server.cluster with parameters of type Message | |
---|---|
void |
ClusteringProvider.clusterTransmitGlobal(Message message)
Advertises a global message to the entire cluster. |
Uses of Message in org.jboss.errai.bus.server.cluster.jgroups |
---|
Methods in org.jboss.errai.bus.server.cluster.jgroups that return Message | |
---|---|
static Message |
JGroupsClusteringProvider.getErraiMessage(org.jgroups.Message message)
|
Methods in org.jboss.errai.bus.server.cluster.jgroups with parameters of type Message | |
---|---|
void |
JGroupsClusteringProvider.callback(Message message)
|
void |
JGroupsClusteringProvider.clusterTransmitGlobal(Message message)
|
Uses of Message in org.jboss.errai.bus.server.cluster.noop |
---|
Methods in org.jboss.errai.bus.server.cluster.noop with parameters of type Message | |
---|---|
void |
NoopClusteringProvider.clusterTransmitGlobal(Message message)
|
Uses of Message in org.jboss.errai.bus.server.io |
---|
Methods in org.jboss.errai.bus.server.io that return Message | |
---|---|
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)
|
Methods in org.jboss.errai.bus.server.io that return types with arguments of type Message | |
---|---|
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)
|
Methods in org.jboss.errai.bus.server.io with parameters of type Message | |
---|---|
void |
RemoteServiceCallback.callback(Message message)
Invokes all callback functions that can be associated to the message |
void |
CommandBindingsCallback.callback(Message message)
|
void |
VoidRPCEndpointCallback.callback(Message message)
|
void |
EndpointCallback.callback(Message message)
Invokes the endpoint function based on the details of the message |
void |
ValueReplyRPCEndpointCallback.callback(Message message)
|
void |
ServiceMethodCallback.callback(Message message)
|
void |
AsyncRPCEndpointCallback.callback(Message message)
|
boolean |
DirectDeliveryHandler.deliver(MessageQueue queue,
Message message)
|
boolean |
MessageDeliveryHandler.deliver(MessageQueue queue,
Message message)
This method is responsible for delivering a message into the transport layer. |
boolean |
BufferDeliveryHandler.deliver(MessageQueue queue,
Message message)
|
static void |
BufferHelper.encodeAndWrite(Buffer buffer,
BufferColor bufferColor,
Message message)
|
Object |
ServiceInstanceProvider.get(Message message)
|
Object |
AbstractRPCMethodCallback.invokeMethodFromMessage(Message message)
|
Uses of Message in org.jboss.errai.bus.server.service |
---|
Methods in org.jboss.errai.bus.server.service that return Message | |
---|---|
Message |
MessageBusProxy.getDeadLetterMessage(String messageId)
|
Methods in org.jboss.errai.bus.server.service with parameters of type Message | |
---|---|
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 |
Method parameters in org.jboss.errai.bus.server.service with type arguments of type Message | |
---|---|
void |
ErraiServiceImpl.store(Collection<Message> messages)
|
void |
ErraiService.store(Collection<Message> messages)
Stores a collection of messages/ |
Uses of Message in org.jboss.errai.bus.server.util |
---|
Methods in org.jboss.errai.bus.server.util with parameters of type Message | |
---|---|
static LocalContext |
LocalContext.get(Message message)
|
static SessionContext |
SessionContext.get(Message message)
|
static ServerLaundryList |
ServerLaundryList.get(Message message)
|
Uses of Message in org.jboss.errai.cdi.server |
---|
Methods in org.jboss.errai.cdi.server with parameters of type Message | |
---|---|
static QueueSession |
CDIServerUtil.getSession(Message message)
|
Uses of Message in org.jboss.errai.cdi.server.events |
---|
Methods in org.jboss.errai.cdi.server.events with parameters of type Message | |
---|---|
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)
|
Uses of Message in org.jboss.errai.enterprise.client.cdi |
---|
Methods in org.jboss.errai.enterprise.client.cdi with parameters of type Message | |
---|---|
void |
AbstractCDIEventCallback.callback(Message message)
|
Uses of Message in org.jboss.errai.enterprise.client.cdi.api |
---|
Methods in org.jboss.errai.enterprise.client.cdi.api with parameters of type Message | |
---|---|
static void |
CDI.consumeEventFromMessage(Message message)
|
Uses of Message in org.jboss.errai.otec.client |
---|
Methods in org.jboss.errai.otec.client with parameters of type Message | |
---|---|
void |
EntitySyncCallback.callback(Message message)
|
Uses of Message in org.jboss.errai.tools.monitoring |
---|
Methods in org.jboss.errai.tools.monitoring that return Message | |
---|---|
static Message |
UiHelper.decodeAndDemarshall(String json)
|
static Message |
UiHelper.uglyReEncode(String message)
|
Methods in org.jboss.errai.tools.monitoring with parameters of type Message | |
---|---|
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)
|
|
Errai 3.0.1-SNAPSHOT | |||||||||
PREV NEXT | FRAMES NO FRAMES |