Package org.apache.activemq.broker.region.virtual

Examples of org.apache.activemq.broker.region.virtual.CompositeTopic

603
604
605
606
607
608
609
610
611
612
613
        for (Object vd : filter(virtualDestinationInterceptor, DtoVirtualDestinationInterceptor.VirtualDestinations.class)) {
            for (Object vt : filter(vd, DtoVirtualTopic.class)) {
                answer.add(fromDto(vt, new VirtualTopic()));
            }
            for (Object vt : filter(vd, DtoCompositeTopic.class)) {
                answer.add(fromDto(vt, new CompositeTopic()));
            }
            for (Object vt : filter(vd, DtoCompositeQueue.class)) {
                answer.add(fromDto(vt, new CompositeQueue()));
            }
        }
View Full Code Here
550
551
552
553
554
555
556
557
558
559
560
        for (Object vd : filter(virtualDestinationInterceptor, DtoVirtualDestinationInterceptor.VirtualDestinations.class)) {
            for (Object vt : filter(vd, DtoVirtualTopic.class)) {
                answer.add(fromDto(vt, new VirtualTopic()));
            }
            for (Object vt : filter(vd, DtoCompositeTopic.class)) {
                answer.add(fromDto(vt, new CompositeTopic()));
            }
            for (Object vt : filter(vd, DtoCompositeQueue.class)) {
                answer.add(fromDto(vt, new CompositeQueue()));
            }
        }
View Full Code Here
602
603
604
605
606
607
608
609
610
611
612
        for (Object vd : filter(virtualDestinationInterceptor, DtoVirtualDestinationInterceptor.VirtualDestinations.class)) {
            for (Object vt : filter(vd, DtoVirtualTopic.class)) {
                answer.add(fromDto(vt, new VirtualTopic()));
            }
            for (Object vt : filter(vd, DtoCompositeTopic.class)) {
                answer.add(fromDto(vt, new CompositeTopic()));
            }
            for (Object vt : filter(vd, DtoCompositeQueue.class)) {
                answer.add(fromDto(vt, new CompositeQueue()));
            }
        }
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
        brokerService.setPersistent(isPersistent());
        brokerService.setAdvisorySupport(false);
        brokerService.setSchedulerSupport(isSchedulerSupportEnabled());
        brokerService.setPopulateJMSXUserID(true);

        final CompositeTopic compositeTopic = new CompositeTopic();
        compositeTopic.setName(COMPOSITE_TOPIC);
        final ArrayList<ActiveMQDestination> forwardDestinations = new ArrayList<ActiveMQDestination>();
        forwardDestinations.add(new ActiveMQQueue(FORWARD_QUEUE));
        forwardDestinations.add(new ActiveMQTopic(FORWARD_TOPIC));
        compositeTopic.setForwardTo(forwardDestinations);
        // NOTE: allows retained messages to be set on the Composite
        compositeTopic.setForwardOnly(false);

        final VirtualDestinationInterceptor destinationInterceptor = new VirtualDestinationInterceptor();
        destinationInterceptor.setVirtualDestinations(new VirtualDestination[] {compositeTopic} );
        brokerService.setDestinationInterceptors(new DestinationInterceptor[] { destinationInterceptor });
    }
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
        defaultEntry.setOptimizedDispatch(true);
        defaultEntry.setCursorMemoryHighWaterMark(110);
        destPolicyMap.setDefaultEntry(defaultEntry);
        brokerService.setDestinationPolicy(destPolicyMap);

        CompositeTopic route = new CompositeTopic();
        route.setName("target");
        route.setForwardOnly(true);
        route.setConcurrentSend(concurrentSend);
        Collection<ActiveMQQueue> routes = new ArrayList<ActiveMQQueue>();
        for (int i=0; i<fanoutCount; i++) {
            routes.add(new ActiveMQQueue("route." + i));
        }
        route.setForwardTo(routes);
        VirtualDestinationInterceptor interceptor = new VirtualDestinationInterceptor();
        interceptor.setVirtualDestinations(new VirtualDestination[]{route});
        brokerService.setDestinationInterceptors(new DestinationInterceptor[]{interceptor});
        brokerService.start();
View Full Code Here
TOP

Related Classes of org.apache.activemq.broker.region.virtual.CompositeTopic

  • org.apache.activemq.broker.virtual.VirtualDestPerfTest
  • org.apache.activemq.command.ActiveMQTopic
  • org.apache.activemq.plugin.RuntimeConfigurationBroker
  • org.apache.activemq.transport.mqtt.MQTTCompositeQueueRetainedTest
    • 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.