## org.hornetq.rest.queue.push
Class PushConsumerResource

    java.lang.Object
      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.