ome.smuggler.config.wiring.omero

Class SessionQBeans

java.lang.Object

ome.smuggler.config.wiring.omero.SessionQBeans

@Configuration
public class SessionQBeans
extends java.lang.Object

Singleton beans for HornetQ client resources that have to be shared and reused.

Constructor Summary

Constructors

Constructor and Description
SessionQBeans()

Method Summary

Modifier and Type	Method and Description
DequeueTask<QueuedOmeroKeepAlive>	dequeueSessionTask(QChannelFactory<QueuedOmeroKeepAlive> factory, OmeroEnv env, SessionService service)
QChannelFactory<QueuedOmeroKeepAlive>	sessionChannelFactory(ServerConnector connector, OmeroSessionQConfig qConfig)
ChannelSource<QueuedOmeroKeepAlive>	sessionSourceChannel(QChannelFactory<QueuedOmeroKeepAlive> factory)

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionQBeans

public SessionQBeans()

Method Detail

sessionChannelFactory

@Bean
public QChannelFactory<QueuedOmeroKeepAlive> sessionChannelFactory(ServerConnector connector,
                                                                         OmeroSessionQConfig qConfig)

sessionSourceChannel

@Bean
public ChannelSource<QueuedOmeroKeepAlive> sessionSourceChannel(QChannelFactory<QueuedOmeroKeepAlive> factory)
                                                               throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

dequeueSessionTask

@Bean
public DequeueTask<QueuedOmeroKeepAlive> dequeueSessionTask(QChannelFactory<QueuedOmeroKeepAlive> factory,
                                                                  OmeroEnv env,
                                                                  SessionService service)
                                                           throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException