|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activecluster.impl.DefaultClusterFactory
A Factory of DefaultCluster instances
Constructor Summary | |
DefaultClusterFactory(ConnectionFactory connectionFactory)
|
|
DefaultClusterFactory(ConnectionFactory connectionFactory,
boolean transacted,
int acknowledgeMode,
String dataTopicPrefix,
long inactiveTime)
|
Method Summary | |
protected Cluster |
createCluster(Connection connection,
Session session,
Topic groupDestination)
|
Cluster |
createCluster(String topic)
Creates a new cluster connection using the given topic name |
Cluster |
createCluster(Topic groupDestination)
Creates a new cluster connection using the given group |
protected MessageProducer |
createProducer(Session session,
Topic groupDestination)
|
protected Session |
createSession(Connection connection)
|
int |
getAcknowledgeMode()
|
ConnectionFactory |
getConnectionFactory()
|
String |
getDataTopicPrefix()
|
int |
getDeliveryMode()
|
long |
getInactiveTime()
|
boolean |
isTransacted()
|
boolean |
isUseQueueForInbox()
|
void |
setAcknowledgeMode(int acknowledgeMode)
|
void |
setConnectionFactory(ConnectionFactory connectionFactory)
|
void |
setDataTopicPrefix(String dataTopicPrefix)
|
void |
setDeliveryMode(int deliveryMode)
Sets the delivery mode of the group based producer |
void |
setInactiveTime(long inactiveTime)
|
void |
setTransacted(boolean transacted)
|
void |
setUseQueueForInbox(boolean useQueueForInbox)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public DefaultClusterFactory(ConnectionFactory connectionFactory, boolean transacted, int acknowledgeMode, String dataTopicPrefix, long inactiveTime)
public DefaultClusterFactory(ConnectionFactory connectionFactory)
Method Detail |
public Cluster createCluster(Topic groupDestination) throws ClusterException, JMSException
ClusterFactory
createCluster
in interface ClusterFactory
groupDestination
-
ClusterException
JMSException
public Cluster createCluster(String topic) throws ClusterException, JMSException
ClusterFactory
createCluster
in interface ClusterFactory
topic
- is the name of the topic to use
ClusterException
JMSException
public String getDataTopicPrefix()
public void setDataTopicPrefix(String dataTopicPrefix)
public int getAcknowledgeMode()
public void setAcknowledgeMode(int acknowledgeMode)
public long getInactiveTime()
public void setInactiveTime(long inactiveTime)
public boolean isTransacted()
public void setTransacted(boolean transacted)
public boolean isUseQueueForInbox()
public void setUseQueueForInbox(boolean useQueueForInbox)
public ConnectionFactory getConnectionFactory()
public void setConnectionFactory(ConnectionFactory connectionFactory)
public int getDeliveryMode()
public void setDeliveryMode(int deliveryMode)
protected Cluster createCluster(Connection connection, Session session, Topic groupDestination) throws JMSException
JMSException
protected MessageProducer createProducer(Session session, Topic groupDestination) throws JMSException
JMSException
protected Session createSession(Connection connection) throws JMSException
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |