Package com.levigo.jadice.server.jms.core

Class JMSRequestEndpoint

java.lang.Object

com.levigo.jadice.server.jms.core.JMSRequestEndpoint

All Implemented Interfaces:

RequestEndpoint<JMSJobExecutionContext>, org.springframework.context.Lifecycle, org.springframework.jmx.export.naming.SelfNaming

@ManagedResource(description="JMS request endpoint")
public class JMSRequestEndpoint
extends Object
implements RequestEndpoint<JMSJobExecutionContext>, org.springframework.context.Lifecycle, org.springframework.jmx.export.naming.SelfNaming

The JMS specific implementation of a RequestEndpoint.

Since:

jadice server 5.5.0.0

Constructor Summary

Constructors

Constructor	Description
JMSRequestEndpoint()

Method Summary

Modifier and Type	Method	Description
javax.jms.QueueConnectionFactory	getConnectionFactory()
String	getJmsPassword()
String	getJmsUsername()
int	getKeepAliveMsgPriority()
ObjectName	getObjectName()
String	getRequestQueueName()
JobScheduler	getScheduler()
StreamTransportFactory	getStreamTransportFactory()
javax.jms.QueueConnectionFactory	getWrappedConnectionFactory()	Return a connection factory which delegates to the connection factory set by setConnectionFactory(QueueConnectionFactory), but uses the credentials set via setJmsUsername(String)/ setJmsPassword(String).
boolean	isRunning()
JMSJobExecutionContext	poll()	Poll for a new incoming job request which is wrapped by a JobExecutionContext
void	setConnectionFactory(javax.jms.QueueConnectionFactory factory)
void	setJmsPassword(String jmsPassword)
void	setJmsUsername(String jmsUsername)
void	setKeepAliveMsgPriority(int keepAliveMsgPriority)
void	setRequestQueueName(String queueName)
void	setScheduler(JobScheduler scheduler)
void	setStreamTransportFactory(StreamTransportFactory transport)
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JMSRequestEndpoint

public JMSRequestEndpoint()

Method Detail

poll

public JMSJobExecutionContext poll()
                            throws Exception

Description copied from interface: RequestEndpoint

Poll for a new incoming job request which is wrapped by a JobExecutionContext

Specified by:

poll in interface RequestEndpoint<JMSJobExecutionContext>

Returns:

A new RequestEndpoint or null if no new request is pending

Throws:

Exception - in case of an error during polling

start

@ManagedOperation(description="Starts this JMS request endpoint")
public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

@ManagedOperation(description="Stops this JMS request endpoint")
public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

isRunning

@ManagedAttribute(description="Checks if the JMS request endpoint is running")
public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

getConnectionFactory

public javax.jms.QueueConnectionFactory getConnectionFactory()

setConnectionFactory

public void setConnectionFactory(javax.jms.QueueConnectionFactory factory)

getWrappedConnectionFactory

public javax.jms.QueueConnectionFactory getWrappedConnectionFactory()

Return a connection factory which delegates to the connection factory set by setConnectionFactory(QueueConnectionFactory), but uses the credentials set via setJmsUsername(String)/ setJmsPassword(String).

Returns:

a QueueConnectionFactory that uses credentials as described above.

See Also:

setJmsUsername(String), setJmsPassword(String)

getRequestQueueName

@ManagedAttribute(description="The queue name this jadice server instance is listening on")
public String getRequestQueueName()

setRequestQueueName

public void setRequestQueueName(String queueName)

getStreamTransportFactory

public StreamTransportFactory getStreamTransportFactory()

setStreamTransportFactory

public void setStreamTransportFactory(StreamTransportFactory transport)

getJmsPassword

public String getJmsPassword()

getJmsUsername

public String getJmsUsername()

setJmsPassword

public void setJmsPassword(String jmsPassword)

setJmsUsername

public void setJmsUsername(String jmsUsername)

getScheduler

public JobScheduler getScheduler()

setScheduler

public void setScheduler(JobScheduler scheduler)

getObjectName

public ObjectName getObjectName()
                         throws MalformedObjectNameException

Specified by:

getObjectName in interface org.springframework.jmx.export.naming.SelfNaming

Throws:

MalformedObjectNameException

setKeepAliveMsgPriority

public void setKeepAliveMsgPriority(int keepAliveMsgPriority)

getKeepAliveMsgPriority

public int getKeepAliveMsgPriority()