@ManagedResource(description="JMS request endpoint") public class JMSRequestEndpoint extends Object implements RequestEndpoint<JMSJobExecutionContext>, org.springframework.context.Lifecycle, org.springframework.jmx.export.naming.SelfNaming
RequestEndpoint
.Constructor and Description |
---|
JMSRequestEndpoint() |
public JMSJobExecutionContext poll() throws Exception
RequestEndpoint
JobExecutionContext
poll
in interface RequestEndpoint<JMSJobExecutionContext>
RequestEndpoint
or null
if no new request is pendingException
@ManagedOperation(description="Starts this JMS request endpoint") public void start()
start
in interface org.springframework.context.Lifecycle
@ManagedOperation(description="Stops this JMS request endpoint") public void stop()
stop
in interface org.springframework.context.Lifecycle
@ManagedAttribute(description="Checks if the JMS request endpoint is running") public boolean isRunning()
isRunning
in interface org.springframework.context.Lifecycle
public javax.jms.QueueConnectionFactory getConnectionFactory()
public void setConnectionFactory(javax.jms.QueueConnectionFactory factory)
public javax.jms.QueueConnectionFactory getWrappedConnectionFactory()
setConnectionFactory(QueueConnectionFactory)
, but uses the credentials set via
setJmsUsername(String)
/ setJmsPassword(String)
.QueueConnectionFactory
that uses credentials as described above.setJmsUsername(String)
,
setJmsPassword(String)
@ManagedAttribute(description="The queue name this jadice server instance is listening on") public String getRequestQueueName()
public void setRequestQueueName(String queueName)
public StreamTransportFactory getStreamTransportFactory()
public void setStreamTransportFactory(StreamTransportFactory transport)
public String getJmsPassword()
public String getJmsUsername()
public void setJmsPassword(String jmsPassword)
public void setJmsUsername(String jmsUsername)
public JobScheduler getScheduler()
public void setScheduler(JobScheduler scheduler)
public ObjectName getObjectName() throws MalformedObjectNameException
getObjectName
in interface org.springframework.jmx.export.naming.SelfNaming
MalformedObjectNameException
Copyright © 2017 levigo holding gmbh. All rights reserved.