public final class DispatchMessageSender extends Object implements MessageSenderService, Startable, Stoppable
Modifier and Type | Field and Description |
---|---|
static String |
CHANNEL_INJECT |
static String |
CLASSLOADER |
static String |
CLUSTER_NAME |
static String |
CONFIGURATION_FILE |
static String |
JGROUPS_PREFIX |
static String |
MUX_ID |
Constructor and Description |
---|
DispatchMessageSender() |
Modifier and Type | Method and Description |
---|---|
Address |
getAddress()
Get sender's address.
|
View |
getView()
Get current view.
|
void |
send(Message message,
boolean synchronous,
long timeout)
Send message.
|
void |
start(Properties props,
BuildContext context)
Start phase notification.
|
void |
stop()
Stop phase notification
|
public static final String JGROUPS_PREFIX
public static final String CONFIGURATION_FILE
public static final String CLUSTER_NAME
public static final String CHANNEL_INJECT
public static final String CLASSLOADER
public static final String MUX_ID
public Address getAddress()
MessageSenderService
getAddress
in interface MessageSenderService
public View getView()
MessageSenderService
getView
in interface MessageSenderService
public void send(Message message, boolean synchronous, long timeout) throws Exception
MessageSenderService
send
in interface MessageSenderService
message
- the JGroups messagesynchronous
- set to true if we need to block until an ACK is receivedtimeout
- in millisecondsException
- for any errorpublic void start(Properties props, BuildContext context)
Startable
Copyright © 2006-2017 Red Hat, Inc. All Rights Reserved