Examples of route()

Examples of org.jboss.messaging.core.plugin.contract.PostOffice.route()

746
747
748
749
750
751
752
753
754
755
756
        
        
         Message msg2 = CoreMessageFactory.createCoreMessage(2, persistentMessage, null);     
         MessageReference ref2 = ms.reference(msg2);
        
         routed = postOffice.route(ref2, new SimpleCondition("topic2"), null);     
         assertTrue(routed);
        
         msgs = receiver4.getMessages();
         assertNotNull(msgs);
         assertEquals(1, msgs.size());
View Full Code Here

Examples of org.jboss.messaging.core.plugin.contract.PostOffice.route()

843
844
845
846
847
848
849
850
851
852
853
         Message msg2 = CoreMessageFactory.createCoreMessage(2, persistentMessage, null);     
         MessageReference ref2 = ms.reference(msg2);
        
         Transaction tx = tr.createTransaction();
        
         boolean routed = postOffice.route(ref1, new SimpleCondition("topic1"), tx);           
         assertTrue(routed);
         routed = postOffice.route(ref2, new SimpleCondition("topic1"), tx);           
         assertTrue(routed);
              
         List msgs = queue1.browse();
View Full Code Here

Examples of org.jboss.messaging.core.plugin.contract.PostOffice.route()

845
846
847
848
849
850
851
852
853
854
855
        
         Transaction tx = tr.createTransaction();
        
         boolean routed = postOffice.route(ref1, new SimpleCondition("topic1"), tx);           
         assertTrue(routed);
         routed = postOffice.route(ref2, new SimpleCondition("topic1"), tx);           
         assertTrue(routed);
              
         List msgs = queue1.browse();
         assertNotNull(msgs);
         assertTrue(msgs.isEmpty());
View Full Code Here

Examples of org.jboss.soa.esb.actions.cbr.RegexRouter.route()

96
97
98
99
100
101
102
103
104
        ConfigTree configTree = esbConfig.getActionConfig("null-listener", "3");
        RegexRouter router = new RegexRouter();

        router.setConfigTree(configTree);

        List<String> destinations = router.route(null, false, message, objectLists);
        assertEquals("[scat-green]", destinations.toString());
    }
}
View Full Code Here

Examples of org.jboss.soa.esb.actions.cbr.SxcXPathRouter.route()

129
130
131
132
133
134
135
136
137
        ConfigTree configTree = esbConfig.getActionConfig("null-listener", "5");
        SxcXPathRouter router = new SxcXPathRouter();

        router.setConfigTree(configTree);

        List<String> destinations = router.route(null, false, message, objectLists);
        assertEquals("[scat-green]", destinations.toString());       
    }
}
View Full Code Here

Examples of org.jboss.soa.esb.actions.cbr.XPathRouter.route()

127
128
129
130
131
132
133
134
135
        ConfigTree configTree = esbConfig.getActionConfig("null-listener", "5");
        XPathRouter router = new XPathRouter();

        router.setConfigTree(configTree);

        List<String> destinations = router.route(null, false, message, objectLists);
        assertEquals("[scat-green]", destinations.toString());
    }
}
View Full Code Here

Examples of org.jivesoftware.openfire.IQRouter.route()

178
179
180
181
182
183
184
185
186
187
188
            caps.setVerAttribute(newVerAttribute);
            verAttributes.put(packetId, caps);

            final IQRouter iqRouter = XMPPServer.getInstance().getIQRouter();
            iqRouter.addIQResultListener(packetId, this);
            iqRouter.route(iq);
        }
    }

    /**
     * Determines whether or not a particular 'ver' attribute is stored in the
View Full Code Here

Examples of org.jivesoftware.openfire.PacketRouter.route()

276
277
278
279
280
281
282
283
284
285
286
            throw new IllegalArgumentException("Packet with no FROM address was received from component.");
        }
       
        PacketRouter router = XMPPServer.getInstance().getPacketRouter();
        if (router != null) {
            router.route(packet);
        }
    }

    public IQ query(Component component, IQ packet, long timeout) throws ComponentException {
        final LinkedBlockingQueue<IQ> answer = new LinkedBlockingQueue<IQ>(8);
View Full Code Here

Examples of org.jivesoftware.openfire.SessionPacketRouter.route()

183
184
185
186
187
188
189
190
191
192
193
        SessionPacketRouter router = new SessionPacketRouter(session);
        // Connection Manager already validate JIDs so just skip this expensive operation
        router.setSkipJIDValidation(true);
        try {
            router.route(route.getChildElement());
        }
        catch (UnknownStanzaException use) {
            Element extraError = DocumentHelper.createElement(QName.get(
                    "unknown-stanza",
                    "http://jabber.org/protocol/connectionmanager#errors"));
View Full Code Here

Examples of org.mule.module.xml.routing.XmlMessageSplitter.route()

197
198
199
200
201
202
203
204
205
206
207
        MuleMessage message = new DefaultMuleMessage(payload, muleContext);

        assertTrue(splitter.isMatch(message));
        try
        {
            splitter.route(new OutboundRoutingTestEvent(message, (MuleSession) session.proxy(), muleContext));
            fail("Should have thrown an exception, because XSD is not found.");
        }
        catch (IllegalArgumentException iaex)
        {
            assertTrue("Wrong exception?", iaex.getMessage().indexOf(
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.