com.latencybusters.jms.topic
Class LBMTopicPublisher
java.lang.Object
com.latencybusters.jms.LBMMessageProducer
com.latencybusters.jms.topic.LBMTopicPublisher
- All Implemented Interfaces:
- javax.jms.MessageProducer, javax.jms.TopicPublisher
public class LBMTopicPublisher
- extends LBMMessageProducer
- implements javax.jms.TopicPublisher
Constructor Summary |
LBMTopicPublisher(LBMSession session,
com.latencybusters.lbm.LBMContext myContext,
com.latencybusters.lbm.LBMEventQueue evq,
java.util.ArrayList<NameValue> props,
javax.jms.Topic topic,
boolean transacted,
java.lang.String cfName)
This is an internal Method. |
Method Summary |
javax.jms.Topic |
getTopic()
|
void |
publish(javax.jms.Message message)
|
void |
publish(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
|
void |
publish(javax.jms.Topic topic,
javax.jms.Message message)
|
void |
publish(javax.jms.Topic topic,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
|
Methods inherited from class com.latencybusters.jms.LBMMessageProducer |
_send, close, closeSources, commit, dumpAttributeList, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getSource, getTimeToLive, isOpen, rollback, send, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setOptionalPrams, setPriority, setTimeToLive, start, stop |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface javax.jms.MessageProducer |
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive |
LBMTopicPublisher
public LBMTopicPublisher(LBMSession session,
com.latencybusters.lbm.LBMContext myContext,
com.latencybusters.lbm.LBMEventQueue evq,
java.util.ArrayList<NameValue> props,
javax.jms.Topic topic,
boolean transacted,
java.lang.String cfName)
throws javax.jms.JMSException
- This is an internal Method.
- Throws:
javax.jms.JMSException
getTopic
public javax.jms.Topic getTopic()
- Specified by:
getTopic
in interface javax.jms.TopicPublisher
publish
public void publish(javax.jms.Message message)
throws javax.jms.JMSException
- Specified by:
publish
in interface javax.jms.TopicPublisher
- Throws:
javax.jms.JMSException
publish
public void publish(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
throws javax.jms.JMSException
- Specified by:
publish
in interface javax.jms.TopicPublisher
- Throws:
javax.jms.JMSException
publish
public void publish(javax.jms.Topic topic,
javax.jms.Message message)
throws javax.jms.JMSException
- Specified by:
publish
in interface javax.jms.TopicPublisher
- Throws:
javax.jms.JMSException
publish
public void publish(javax.jms.Topic topic,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
throws javax.jms.JMSException
- Specified by:
publish
in interface javax.jms.TopicPublisher
- Throws:
javax.jms.JMSException
All of the documentation and software included in this and any other Informatica, Inc. "Ultra Messaging" Release is Copyright (C) 2004-2014, Informatica Corporation. All rights reserved. Redistribution and use in source and binary forms, with or without modification, are permitted only as covered by the terms of a valid software license agreement with Informatica Inc. Copyright © 2004-2014, Informatica, Inc. All Rights Reserved.