public class ClusterJMSService extends Object implements ClusterService
Modifier and Type | Class and Description |
---|---|
static class |
ClusterJMSService.JMSExceptionListener |
ClusterService.DestinationType
Constructor and Description |
---|
ClusterJMSService() |
Modifier and Type | Method and Description |
---|---|
void |
broadcast(ClusterService.DestinationType type,
String channel,
Serializable object) |
void |
close() |
void |
connect() |
<T> void |
createConsumer(ClusterService.DestinationType type,
String channel,
Class<T> objectMessageClass,
Consumer<T> listener) |
protected javax.jms.Session |
createConsumerSession() |
protected javax.jms.Destination |
createDestination(ClusterService.DestinationType type,
String channel,
javax.jms.Session session) |
boolean |
isAppFormerClustered() |
public void connect()
connect
in interface ClusterService
public <T> void createConsumer(ClusterService.DestinationType type, String channel, Class<T> objectMessageClass, Consumer<T> listener)
createConsumer
in interface ClusterService
public void broadcast(ClusterService.DestinationType type, String channel, Serializable object)
broadcast
in interface ClusterService
protected javax.jms.Destination createDestination(ClusterService.DestinationType type, String channel, javax.jms.Session session) throws javax.jms.JMSException
javax.jms.JMSException
protected javax.jms.Session createConsumerSession()
public boolean isAppFormerClustered()
isAppFormerClustered
in interface ClusterService
public void close()
close
in interface ClusterService
Copyright © 2012–2020 JBoss by Red Hat. All rights reserved.