Package org.apache.activemq.transport.failover

Examples of org.apache.activemq.transport.failover.FailoverTransport

2523
2524
2525
2526
2527
2528
2529
2530
2531
2532
2533
2534
2535
            }
            transportInterruptionProcessingComplete.set(0);
    }

    private void signalInterruptionProcessingNeeded() {
        FailoverTransport failoverTransport = transport.narrow(FailoverTransport.class);
        if (failoverTransport != null) {
            failoverTransport.getStateTracker().transportInterrupted(this.getConnectionInfo().getConnectionId());
            if (LOG.isDebugEnabled()) {
                LOG.debug("notified failover transport (" + failoverTransport
                        + ") of pending interruption processing for: " + this.getConnectionInfo().getConnectionId());
            }
        }
View Full Code Here
648
649
650
651
652
653
654
655
656
657
658
659
        }

        TransactionInfo info = new TransactionInfo(getConnectionId(), null, TransactionInfo.RECOVER);
        try {
            this.connection.checkClosedOrFailed();
            final FailoverTransport failoverTransport = this.connection.getTransport().narrow(FailoverTransport.class);
            if (failoverTransport != null && !failoverTransport.isConnected()) {
                // otherwise call will block on reconnect forfeting any app level periodic check
                XAException xaException = new XAException("Failover transport not connected: " + this.getConnection().getTransport());
                xaException.errorCode = XAException.XAER_RMERR;
                throw xaException;
            }
View Full Code Here
34
35
36
37
38
39
40
41
*/
public class DiscoveryTransportFactory extends FailoverTransportFactory {
       
    public Transport createTransport(CompositeData compositeData) throws IOException {
        Map<String, String> parameters = new HashMap<String, String>(compositeData.getParameters());
        FailoverTransport failoverTransport = createTransport(parameters);
        return createTransport(failoverTransport, compositeData, parameters);
    }
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
        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");
        statesField.setAccessible(true);
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
        // Send the message using the fail over publisher.
        connection3.request(createMessage(producerInfo3, destination, deliveryMode));

        // The message will be sent to one of the brokers.
        FailoverTransport ft = (FailoverTransport)connection3.getTransport().narrow(FailoverTransport.class);

        // See which broker we were connected to.
        StubConnection connectionA;
        StubConnection connectionB;
        TransportConnector serverA;
        if (connector.getServer().getConnectURI().getPort() == ft.getConnectedTransportURI().getPort()) {
            connectionA = connection1;
            connectionB = connection2;
            serverA = connector;
        } else {
            connectionA = connection2;
View Full Code Here
TOP

Related Classes of org.apache.activemq.transport.failover.FailoverTransport

  • org.apache.activemq.ActiveMQConnection
  • org.apache.activemq.ActiveMQXAConnectionFactoryTest
  • org.apache.activemq.bugs.AMQ2364Test
  • org.apache.activemq.bugs.AMQ4950Test
  • org.apache.activemq.command.BrokerInfo
  • org.apache.activemq.command.Command
  • org.apache.activemq.command.ConnectionControl
  • org.apache.activemq.command.MessageDispatch
  • org.apache.activemq.command.MessagePull
  • org.apache.activemq.command.Response
    • 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.