public class JmsPublisher extends java.lang.Object implements Publisher
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
EVENT_HEADER_ATTRIBUTE_NAME_JMS_DELIVERY_MODE |
static java.lang.String |
EVENT_HEADER_ATTRIBUTE_NAME_JMS_PRIORITY |
static java.lang.String |
EVENT_HEADER_ATTRIBUTE_NAME_JMS_TIME_TO_LIVE |
static java.lang.String |
PROPERTY_CONN_DELAY_MULTIPLIER |
static java.lang.String |
PROPERTY_CONN_DELAYINTERVAL |
static java.lang.String |
PROPERTY_KEY_CONNECTION_FACTORY_JNDI_NAME |
static java.lang.String |
PROPERTY_KEY_DEFAULT_DESTINATION |
static java.lang.String |
PROPERTY_KEY_INITIAL_CONTEXT_FACTORY |
static java.lang.String |
PROPERTY_KEY_JMS_CLIENT_ID |
static java.lang.String |
PROPERTY_KEY_PROVIDER_URL |
static java.lang.String |
PROPERTY_MAX_CONNECT_TIME |
Constructor and Description |
---|
JmsPublisher()
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close publisher, includes shutting down any connections, etc.
|
void |
initialize(PublisherContext context)
Context attribute CONNECTION_FACTORY_JNDI_NAME is mandatory and it contains
the String key with which to look up the ConnectionFactory from JMS.
|
void |
publish(WebMessage message)
Publish given WebMessage.
|
public static final java.lang.String PROPERTY_KEY_CONNECTION_FACTORY_JNDI_NAME
public static final java.lang.String PROPERTY_KEY_INITIAL_CONTEXT_FACTORY
public static final java.lang.String PROPERTY_KEY_PROVIDER_URL
public static final java.lang.String PROPERTY_KEY_JMS_CLIENT_ID
public static final java.lang.String PROPERTY_KEY_DEFAULT_DESTINATION
public static final java.lang.String EVENT_HEADER_ATTRIBUTE_NAME_JMS_DELIVERY_MODE
public static final java.lang.String EVENT_HEADER_ATTRIBUTE_NAME_JMS_PRIORITY
public static final java.lang.String EVENT_HEADER_ATTRIBUTE_NAME_JMS_TIME_TO_LIVE
public static final java.lang.String PROPERTY_MAX_CONNECT_TIME
public static final java.lang.String PROPERTY_CONN_DELAYINTERVAL
public static final java.lang.String PROPERTY_CONN_DELAY_MULTIPLIER
public void initialize(PublisherContext context) throws PublisherException
initialize
in interface Publisher
context
- - Context in which the publisher is running.PublisherException
- - if there is initialization error.Publisher.initialize(com.ibm.websphere.webmsg.publisher.PublisherContext)
public void close() throws PublisherException
Publisher
close
in interface Publisher
PublisherException
- If error closing publisher.Publisher.close()
public void publish(WebMessage message) throws PublisherException
publish
in interface Publisher
message
- Message to be published.PublisherException
- If there is any error with publishing the exception.Publisher.publish(WebMessage)