Package org.apache.activemq.broker.region

Examples of org.apache.activemq.broker.region.Subscription

235
236
237
238
239
240
241
242
243
244
245
246
        return objectNameStr;
    }

    @Override
    public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
        Subscription sub = super.addConsumer(context, info);
        SubscriptionKey subscriptionKey = new SubscriptionKey(sub.getContext().getClientId(), sub.getConsumerInfo().getSubscriptionName());
        ObjectName inactiveName = subscriptionKeys.get(subscriptionKey);
        if (inactiveName != null) {
            // if it was inactive, register it
            registerSubscription(context, sub);
        }
View Full Code Here
613
614
615
616
617
618
619
620
621
622
623
    public ObjectName getSubscriberObjectName(Subscription key) {
        return subscriptionMap.get(key);
    }

    public Subscription getSubscriber(ObjectName key) {
        Subscription sub = null;
        for (Entry<Subscription, ObjectName> entry: subscriptionMap.entrySet()) {
            if (entry.getValue().equals(key)) {
                sub = entry.getKey();
                break;
            }
View Full Code Here
271
272
273
274
275
276
277
278
279
280
281
282
        consumerId.setValue(0);
        info.setConsumerId(consumerId);
        info.setDestination(new ActiveMQTopic(topicName));
        info.setSubscriptionName(subscriberName);
        info.setSelector(selector);
        Subscription subscription = broker.addConsumer(context, info);
        broker.removeConsumer(context, info);
        if (subscription != null) {
            return subscription.getObjectName();
        }
        return null;
    }
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
        }
    }

    @Override
    public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
        Subscription answer = next.addConsumer(context, info);
        Broker brokers[] = getListeners();
        for (int i = 0; i < brokers.length; i++) {
            brokers[i].addConsumer(context, info);
        }
        return answer;
View Full Code Here
271
272
273
274
275
276
277
278
279
280
281
282
        consumerId.setValue(0);
        info.setConsumerId(consumerId);
        info.setDestination(new ActiveMQTopic(topicName));
        info.setSubscriptionName(subscriberName);
        info.setSelector(selector);
        Subscription subscription = broker.addConsumer(context, info);
        broker.removeConsumer(context, info);
        if (subscription != null) {
            return subscription.getObjectName();
        }
        return null;
    }
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
87
88
        }
        return rc;
    }

    public void abortConsumer(ObjectName consumerToAbort) {
        Subscription sub = broker.getSubscriber(consumerToAbort);
        if (sub != null) {
            LOG.info("aborting consumer via jmx: " + sub.getConsumerInfo().getConsumerId());          
            strategy.abortConsumer(sub, false);
        } else {
            LOG.warn("cannot resolve subscription matching name: " + consumerToAbort);
        }
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
98
99
        }

    }

    public void abortConnection(ObjectName consumerToAbort) {
        Subscription sub = broker.getSubscriber(consumerToAbort);
        if (sub != null) {
            LOG.info("aborting consumer connection via jmx: " + sub.getConsumerInfo().getConsumerId().getConnectionId());
            strategy.abortConsumer(sub, true);
        } else {
            LOG.warn("cannot resolve subscription matching name: " + consumerToAbort);
        }
    }
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
        fireAdvisory(context, topic, info);       
        connections.put(info.getConnectionId(), info);
    }

    public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
        Subscription answer = next.addConsumer(context, info);

        // Don't advise advisory topics.
        if( !AdvisorySupport.isAdvisoryTopic(info.getDestination()) ) {
            ActiveMQTopic topic = AdvisorySupport.getConsumerAdvisoryTopic(info.getDestination());
            consumers.put(info.getConsumerId(), info);
View Full Code Here
39
40
41
42
43
44
45
46
47
48
        super(broker,destinationStatistics, memoryManager, taskRunnerFactory, destinationFactory);
        regionBroker = broker;
    }

    protected Subscription createSubscription(ConnectionContext context, ConsumerInfo info) throws InvalidSelectorException {
        Subscription sub = super.createSubscription(context, info);
        ObjectName name = regionBroker.registerSubscription(context,sub);
        sub.setObjectName(name);
        return sub;
    }
View Full Code Here
39
40
41
42
43
44
45
46
47
48
        super(regionBroker,destinationStatistics, memoryManager, taskRunnerFactory, destinationFactory);
        this.regionBroker = regionBroker;
    }
   
    protected Subscription createSubscription(ConnectionContext context, ConsumerInfo info) throws InvalidSelectorException {
        Subscription sub = super.createSubscription(context, info);
        ObjectName name = regionBroker.registerSubscription(context,sub);
        sub.setObjectName(name);
        return sub;
    }
View Full Code Here
TOP

Related Classes of org.apache.activemq.broker.region.Subscription

  • org.apache.activemq.advisory.AdvisoryBroker
  • org.apache.activemq.broker.BrokerBroadcaster
  • org.apache.activemq.broker.ft.MasterBroker
  • org.apache.activemq.broker.jmx.AbortSlowConsumerStrategyView
  • org.apache.activemq.broker.jmx.BrokerView
  • org.apache.activemq.broker.jmx.ManagedQueueRegion
  • org.apache.activemq.broker.jmx.ManagedRegionBroker
  • org.apache.activemq.broker.jmx.ManagedTempQueueRegion
  • org.apache.activemq.broker.jmx.ManagedTempTopicRegion
  • org.apache.activemq.broker.jmx.ManagedTopicRegion
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.