org.hornetq.rest.queue.push
Class PushConsumerResource

java.lang.Object
  extended by org.hornetq.rest.queue.push.PushConsumerResource

public class PushConsumerResource
extends java.lang.Object

Version:
$Revision: 1 $
Author:
Bill Burke

Field Summary
protected  java.util.Map<java.lang.String,PushConsumer> consumers
           
protected  java.lang.String destination
           
protected  PushStore pushStore
           
protected  java.util.concurrent.atomic.AtomicLong sessionCounter
           
protected  org.hornetq.api.core.client.ClientSessionFactory sessionFactory
           
protected  java.lang.String startup
           
 
Constructor Summary
PushConsumerResource()
           
 
Method Summary
 void addRegistration(PushRegistration reg)
           
 javax.ws.rs.core.Response create(javax.ws.rs.core.UriInfo uriInfo, PushRegistration registration)
           
 void deleteConsumer(java.lang.String consumerId)
           
 PushRegistration getConsumer(java.lang.String consumerId)
           
 java.util.Map<java.lang.String,PushConsumer> getConsumers()
           
 java.lang.String getDestination()
           
 PushStore getPushStore()
           
 org.hornetq.api.core.client.ClientSessionFactory getSessionFactory()
           
 void setDestination(java.lang.String destination)
           
 void setPushStore(PushStore pushStore)
           
 void setSessionFactory(org.hornetq.api.core.client.ClientSessionFactory sessionFactory)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

consumers

protected java.util.Map<java.lang.String,PushConsumer> consumers

sessionFactory

protected org.hornetq.api.core.client.ClientSessionFactory sessionFactory

destination

protected java.lang.String destination

startup

protected final java.lang.String startup

sessionCounter

protected final java.util.concurrent.atomic.AtomicLong sessionCounter

pushStore

protected PushStore pushStore
Constructor Detail

PushConsumerResource

public PushConsumerResource()
Method Detail

start

public void start()

stop

public void stop()

getPushStore

public PushStore getPushStore()

setPushStore

public void setPushStore(PushStore pushStore)

addRegistration

public void addRegistration(PushRegistration reg)
                     throws java.lang.Exception
Throws:
java.lang.Exception

create

public javax.ws.rs.core.Response create(@Context
                                        javax.ws.rs.core.UriInfo uriInfo,
                                        PushRegistration registration)

getConsumer

public PushRegistration getConsumer(java.lang.String consumerId)

deleteConsumer

public void deleteConsumer(java.lang.String consumerId)

getConsumers

public java.util.Map<java.lang.String,PushConsumer> getConsumers()

getSessionFactory

public org.hornetq.api.core.client.ClientSessionFactory getSessionFactory()

setSessionFactory

public void setSessionFactory(org.hornetq.api.core.client.ClientSessionFactory sessionFactory)

getDestination

public java.lang.String getDestination()

setDestination

public void setDestination(java.lang.String destination)


Copyright © 2013. All Rights Reserved.