Examples of DestinationFilter

Examples of org.activemq.filter.DestinationFilter

182
183
184
185
186
187
188
189
190
191
192
            return new DurableQueueMessageContainer(persistenceAapter, persistenceAapter.createQueueMessageStore(destination.toString()), destination.toString());
        }
    }

    protected Subscription createSubscription() throws JMSException {
        DestinationFilter filter = DestinationFilter.parseFilter(destination);
        ConsumerInfo consumerInfo = createConsumerInfo();

        // lets register the subscription with the manager
        messageContainerManager.addMessageConsumer(client, consumerInfo);
View Full Code Here

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

45
46
47
48
49
50
51
52
53
54
55
    public Destination intercept(final Destination destination) {
        if (destination.getActiveMQDestination().isQueue()) {
            try {
                final Destination mirrorDestination = getMirrorDestination(destination);
                if (mirrorDestination != null) {
                    return new DestinationFilter(destination) {
                        public void send(ProducerBrokerExchange context, Message message) throws Exception {
                            message.setDestination(mirrorDestination.getActiveMQDestination());
                            mirrorDestination.send(context, message);

                            if (isCopyMessage()) {
View Full Code Here

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

71
72
73
74
75
76
77
78
79
80
81
            destinationMap.put(virtualDestination.getVirtualDestination(), virtualDestination);
        }
    }

    protected Destination createCompositeDestination(Destination destination, final List<Destination> destinations) {
        return new DestinationFilter(destination) {
            public void send(ProducerBrokerExchange context, Message messageSend) throws Exception {
                for (Iterator<Destination> iter = destinations.iterator(); iter.hasNext();) {
                    Destination destination = iter.next();
                    destination.send(context, messageSend);
                }
View Full Code Here

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

44
45
46
47
48
49
50
51
52
53
54
        if (destination.getActiveMQDestination().isQueue()) {
            if (!destination.getActiveMQDestination().isTemporary() || brokerService.isUseTempMirroredQueues()) {
                try {
                    final Destination mirrorDestination = getMirrorDestination(destination);
                    if (mirrorDestination != null) {
                        return new DestinationFilter(destination) {
                            public void send(ProducerBrokerExchange context, Message message) throws Exception {
                                message.setDestination(mirrorDestination.getActiveMQDestination());
                                mirrorDestination.send(context, message);
   
                                if (isCopyMessage()) {
View Full Code Here

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

84
85
86
87
88
89
90
91
92
93
94
            destinationMap.put(virtualDestination.getVirtualDestination(), virtualDestination);
        }
    }

    protected Destination createCompositeDestination(Destination destination, final List<Destination> destinations) {
        return new DestinationFilter(destination) {
            public void send(ProducerBrokerExchange context, Message messageSend) throws Exception {
                for (Iterator<Destination> iter = destinations.iterator(); iter.hasNext();) {
                    Destination destination = iter.next();
                    destination.send(context, messageSend);
                }
View Full Code Here

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

74
75
76
77
78
79
80
81
82
83
84
            destinationMap.put(virtualDestination.getVirtualDestination(), virtualDestination);
        }
    }

    protected Destination createCompositeDestination(Destination destination, final List destinations) {
        return new DestinationFilter(destination) {
            public void send(ConnectionContext context, Message messageSend) throws Exception {
                for (Iterator iter = destinations.iterator(); iter.hasNext();) {
                    Destination destination = (Destination) iter.next();
                    destination.send(context, messageSend);
                }
View Full Code Here

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

245
246
247
248
249
250
251
252
253
254
255
         */
        public Destination intercept(final Destination destination) {
            LOG.info("intercept({})", destination.getName());

            if (!destination.getActiveMQDestination().getPhysicalName().startsWith("ActiveMQ")) {
                return new DestinationFilter(destination) {
                  public void send(ProducerBrokerExchange context, Message message) throws Exception {
                    // Send message to Destination
                    if (LOG.isDebugEnabled()) {
                      LOG.debug("SimpleDestinationInterceptor: Sending message to destination:"
                          + this.getActiveMQDestination().getPhysicalName());
View Full Code Here

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

44
45
46
47
48
49
50
51
52
53
54
        if (destination.getActiveMQDestination().isQueue()) {
            if (!destination.getActiveMQDestination().isTemporary() || brokerService.isUseTempMirroredQueues()) {
                try {
                    final Destination mirrorDestination = getMirrorDestination(destination);
                    if (mirrorDestination != null) {
                        return new DestinationFilter(destination) {
                            public void send(ProducerBrokerExchange context, Message message) throws Exception {
                                message.setDestination(mirrorDestination.getActiveMQDestination());
                                mirrorDestination.send(context, message);
   
                                if (isCopyMessage()) {
View Full Code Here

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

84
85
86
87
88
89
90
91
92
93
94
            destinationMap.put(virtualDestination.getVirtualDestination(), virtualDestination);
        }
    }

    protected Destination createCompositeDestination(Destination destination, final List<Destination> destinations) {
        return new DestinationFilter(destination) {
            public void send(ProducerBrokerExchange context, Message messageSend) throws Exception {
                for (Iterator<Destination> iter = destinations.iterator(); iter.hasNext();) {
                    Destination destination = iter.next();
                    destination.send(context, messageSend);
                }
View Full Code Here

Examples of org.apache.activemq.filter.DestinationFilter

762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
        // Are we not bridging temp destinations?
        if (destination.isTemporary() && !configuration.isBridgeTempDestinations()) {
            return false;
        }

        DestinationFilter filter = DestinationFilter.parseFilter(destination);
        ActiveMQDestination[] dests = excludedDestinations;
        if (dests != null && dests.length > 0) {
            for (int i = 0; i < dests.length; i++) {
                ActiveMQDestination match = dests[i];
                if (match != null && filter.matches(match)) {
                    return false;
                }
            }
        }
        dests = dynamicallyIncludedDestinations;
        if (dests != null && dests.length > 0) {
            for (int i = 0; i < dests.length; i++) {
                ActiveMQDestination match = dests[i];
                if (match != null && filter.matches(match)) {
                    return true;
                }
            }
            return false;
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.