Package org.apache.activemq.transport

Examples of org.apache.activemq.transport.ResponseCorrelator

33
34
35
36
37
38
39
40
public class MockTransportFactory extends TransportFactory {

    public Transport doConnect(URI location) throws URISyntaxException, Exception {
        Transport transport = createTransport(URISupport.parseComposite(location));
        transport =  new MutexTransport(transport);
        transport = new ResponseCorrelator(transport);
        return transport;
    }
View Full Code Here
298
299
300
301
302
303
304
305
306
307
308
309
310
311
        final VMTestTransportListener remoteListener = new VMTestTransportListener(remoteReceived);
        remote.setTransportListener(remoteListener);

        final Response[] answer = new Response[1];
        ResponseCorrelator responseCorrelator = new ResponseCorrelator(local);
        responseCorrelator.setTransportListener(new VMTestTransportListener(localReceived));
        responseCorrelator.start();
        responseCorrelator.asyncRequest(new DummyCommand(), new ResponseCallback() {
            @Override
            public void onCompletion(FutureResponse resp) {
                try {
                    answer[0] = resp.getResult();
                } catch (IOException e) {
View Full Code Here
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
                HashMap<String, String> map = new HashMap<String, String>(URISupport.parseParamters(uri));
                map.put("network", "true");
                map.put("async", "false");
                uri = URISupport.createURIWithQuery(uri, URISupport.createQueryString(map));
                Transport localTransport = TransportFactory.connect(uri);
                Transport remoteBridgeTransport = new ResponseCorrelator(transport);
                duplexBridge = NetworkBridgeFactory.createBridge(config, localTransport, remoteBridgeTransport);
                duplexBridge.setBrokerService(broker.getBrokerService());
                // now turn duplex off this side
                info.setDuplexConnection(false);
                duplexBridge.setCreatedByDuplex(true);
View Full Code Here
34
35
36
37
38
39
40
41
42
43
44
    @Override
    public Transport doConnect(URI location) throws IOException {
        try {
            Transport transport = createTransport(URISupport.parseComposite(location));
            transport = new MutexTransport(transport);
            transport = new ResponseCorrelator(transport);
            return transport;
        } catch (URISyntaxException e) {
            throw new IOException("Invalid location: " + location);
        }
    }
View Full Code Here
97
98
99
100
101
102
103
104
     * @param transport
     * @return the Transport
     */
    public static Transport configure(Transport transport) {
        transport = new MutexTransport(transport);
        transport = new ResponseCorrelator(transport);
        return transport;
    }
View Full Code Here
1328
1329
1330
1331
1332
1333
1334
1335
1336
1337
1338
                }
                Transport localTransport = NetworkBridgeFactory.createLocalTransport(broker);
                Transport remoteBridgeTransport = transport;
                if (! (remoteBridgeTransport instanceof ResponseCorrelator)) {
                    // the vm transport case is already wrapped
                    remoteBridgeTransport = new ResponseCorrelator(remoteBridgeTransport);
                }
                String duplexName = localTransport.toString();
                if (duplexName.contains("#")) {
                    duplexName = duplexName.substring(duplexName.lastIndexOf("#"));
                }
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
99
        latch.await();
        consumer.close();
        session.close();

        ResponseCorrelator respCorr = (ResponseCorrelator) connection.getTransport();
        MutexTransport mutexTrans = (MutexTransport) respCorr.getNext();
        FailoverTransport failoverTrans = (FailoverTransport) mutexTrans.getNext();
        Field stateTrackerField = FailoverTransport.class.getDeclaredField("stateTracker");
        stateTrackerField.setAccessible(true);
        ConnectionStateTracker stateTracker = (ConnectionStateTracker) stateTrackerField.get(failoverTrans);
        Field statesField = ConnectionStateTracker.class.getDeclaredField("connectionStates");
View Full Code Here
1289
1290
1291
1292
1293
1294
1295
1296
1297
1298
1299
                }
                Transport localTransport = NetworkBridgeFactory.createLocalTransport(broker);
                Transport remoteBridgeTransport = transport;
                if (! (remoteBridgeTransport instanceof ResponseCorrelator)) {
                    // the vm transport case is already wrapped
                    remoteBridgeTransport = new ResponseCorrelator(remoteBridgeTransport);
                }
                String duplexName = localTransport.toString();
                if (duplexName.contains("#")) {
                    duplexName = duplexName.substring(duplexName.lastIndexOf("#"));
                }
View Full Code Here
1315
1316
1317
1318
1319
1320
1321
1322
1323
1324
1325
                }
                Transport localTransport = NetworkBridgeFactory.createLocalTransport(broker);
                Transport remoteBridgeTransport = transport;
                if (! (remoteBridgeTransport instanceof ResponseCorrelator)) {
                    // the vm transport case is already wrapped
                    remoteBridgeTransport = new ResponseCorrelator(remoteBridgeTransport);
                }
                String duplexName = localTransport.toString();
                if (duplexName.contains("#")) {
                    duplexName = duplexName.substring(duplexName.lastIndexOf("#"));
                }
View Full Code Here
72
73
74
75
76
77
78
79
     */
    public MasterBroker(MutableBrokerFilter parent, Transport transport) {
        super(parent);
        this.slave = transport;
        this.slave = new MutexTransport(slave);
        this.slave = new ResponseCorrelator(slave);
        this.slave.setTransportListener(transport.getTransportListener());
    }
View Full Code Here
TOP

Related Classes of org.apache.activemq.transport.ResponseCorrelator

  • org.apache.activemq.broker.ft.MasterBroker
  • org.apache.activemq.broker.TransportConnection
  • org.apache.activemq.bugs.AMQ2364Test
  • org.apache.activemq.command.Command
  • org.apache.activemq.command.ExceptionResponse
  • org.apache.activemq.command.Response
  • org.apache.activemq.transport.failover.FailoverTransportFactory
  • org.apache.activemq.transport.fanout.FanoutTransportFactory
  • org.apache.activemq.transport.mock.MockTransportFactory
  • org.apache.activemq.transport.vm.VMTransportServer
    • 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.