|
Brooklyn | |||||||
FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectbrooklyn.entity.basic.AbstractEntity
brooklyn.entity.basic.SoftwareProcessImpl
brooklyn.entity.messaging.jms.JMSBrokerImpl
public abstract class JMSBrokerImpl extends SoftwareProcessImpl
Field Summary |
---|
Fields inherited from class SoftwareProcessImpl | |
---|---|
connectedSensors |
Fields inherited from class AbstractEntity | |
---|---|
EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, LOG, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED, _subscriptionTracker, managementSupport, tempWorkings |
Constructor Summary | |
JMSBrokerImpl()
|
Method Summary | |
---|---|
void
|
addQueue(java.lang.String name)
|
void
|
addQueue(java.lang.String name, java.util.Map properties)
|
void
|
addTopic(java.lang.String name)
|
void
|
addTopic(java.lang.String name, java.util.Map properties)
|
JMSBrokerImpl
|
configure(java.util.Map properties)
|
protected void
|
connectSensors()
|
Q
|
createQueue(java.util.Map properties)
|
java.lang.Object
|
createTopic(java.util.Map properties)
|
java.util.Collection
|
getQueueNames()
|
java.util.Map
|
getQueues()
|
java.util.Collection
|
getTopicNames()
|
java.util.Map
|
getTopics()
|
protected void
|
postStart()
|
void
|
preStop()
|
void
|
setBrokerUrl()
|
Constructor Detail |
---|
public JMSBrokerImpl()
Method Detail |
---|
@Override public void addQueue(java.lang.String name)
} public void addQueue(java.lang.String name, java.util.Map properties)
@Override public void addTopic(java.lang.String name)
} public void addTopic(java.lang.String name, java.util.Map properties)
@Override public JMSBrokerImpl configure(java.util.Map properties)
@Override protected void connectSensors()
addTopic(name, MutableMap.of()); public Q createQueue(java.util.Map properties)
public java.lang.Object createTopic(java.util.Map properties)
@Override public java.util.Collection getQueueNames()
@Override public java.util.Map getQueues()
@Override public java.util.Collection getTopicNames()
@Override public java.util.Map getTopics()
protected void postStart() { su protected void postStart()
// (e.g. in CI have seen activemq "BrokerStoppedException" thrown in queue.destroy()). public void preStop()
@Override public void setBrokerUrl()
Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.