Package org.apache.activemq.command

Examples of org.apache.activemq.command.ConnectionControl

155
156
157
158
159
160
161
162
            } else {
                message = session.createTextMessage(payloadString);
            }
            producer.send(message, DeliveryMode.PERSISTENT, 5, expiry);
        }
        connection.syncSendPacket(new ConnectionControl());
        connection.close();
    }
View Full Code Here
844
845
846
847
848
849
850
851
852
853
854
855
    }

    protected void restoreTransport(Transport t) throws Exception, IOException {
        t.start();
        // send information to the broker - informing it we are an ft client
        ConnectionControl cc = new ConnectionControl();
        cc.setFaultTolerant(true);
        t.oneway(cc);
        stateTracker.restore(t);
        Map<Integer, Command> tmpMap = null;
        synchronized (requestMap) {
            tmpMap = new LinkedHashMap<Integer, Command>(requestMap);
View Full Code Here
581
582
583
584
585
586
587
588
589
590
591
592
    }

    protected void restoreTransport(Transport t) throws Exception, IOException {
        t.start();
        //send information to the broker - informing it we are an ft client
        ConnectionControl cc = new ConnectionControl();
        cc.setFaultTolerant(true);
        t.oneway(cc);
        stateTracker.restore(t);
        Map tmpMap = null;
        synchronized(requestMap) {
            tmpMap = new LinkedHashMap<Integer, Command>(requestMap);
View Full Code Here
665
666
667
668
669
670
671
672
673
674
675
          LOG.warn("Failed to add Connection",e);
          throw e;
        }
        if (info.isManageable() && broker.isFaultTolerantConfiguration()) {
            // send ConnectionCommand
            ConnectionControl command = new ConnectionControl();
            command.setFaultTolerant(broker.isFaultTolerantConfiguration());
            dispatchAsync(command);
        }
        return null;
    }
View Full Code Here
405
406
407
408
409
410
411
412
413
414
                    String shuffle = peerBrokers.removeFirst();
                    peerBrokers.addLast(shuffle);
                }
            }
        }
        ConnectionControl control = new ConnectionControl();
        control.setConnectedBrokers(connectedBrokers);
        control.setRebalanceConnection(rebalance);
        return control;
    }
View Full Code Here
437
438
439
440
441
442
443
444
445
446
447
    }

    @Override
    public void updateClientClusterInfo() {
        if (isRebalanceClusterClients() || isUpdateClusterClients()) {
            ConnectionControl control = getConnectionControl();
            for (Connection c : this.connections) {
                c.updateClient(control);
                if (isRebalanceClusterClients()) {
                    control = getConnectionControl();
                }
View Full Code Here
834
835
836
837
838
839
840
841
842
843
844
845
    }

    protected void restoreTransport(Transport t) throws Exception, IOException {
        t.start();
        // send information to the broker - informing it we are an ft client
        ConnectionControl cc = new ConnectionControl();
        cc.setFaultTolerant(true);
        t.oneway(cc);
        stateTracker.restore(t);
        Map<Integer, Command> tmpMap = null;
        synchronized (requestMap) {
            tmpMap = new LinkedHashMap<Integer, Command>(requestMap);
View Full Code Here
51
52
53
54
55
56
57
   
    /**
     * @return a new object instance
     */
    public DataStructure createObject() {
        return new ConnectionControl();
    }
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
75
76
     * @throws IOException
     */
    public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn, BooleanStream bs) throws IOException {
        super.tightUnmarshal(wireFormat, o, dataIn, bs);

        ConnectionControl info = (ConnectionControl)o;
        info.setClose(bs.readBoolean());
        info.setExit(bs.readBoolean());
        info.setFaultTolerant(bs.readBoolean());
        info.setResume(bs.readBoolean());
        info.setSuspend(bs.readBoolean());

    }
View Full Code Here
51
52
53
54
55
56
57
   
    /**
     * @return a new object instance
     */
    public DataStructure createObject() {
        return new ConnectionControl();
    }
View Full Code Here
TOP

Related Classes of org.apache.activemq.command.ConnectionControl

  • org.apache.activemq.broker.ft.MasterBroker
  • org.apache.activemq.broker.TransportConnection
  • org.apache.activemq.broker.TransportConnector
  • org.apache.activemq.bugs.AMQ4157Test
  • org.apache.activemq.openwire.v1.ConnectionControlMarshaller
  • org.apache.activemq.openwire.v1.ConnectionControlTest
  • org.apache.activemq.openwire.v2.ConnectionControlMarshaller
  • org.apache.activemq.openwire.v2.ConnectionControlTest
  • org.apache.activemq.openwire.v3.ConnectionControlMarshaller
  • org.apache.activemq.openwire.v3.ConnectionControlTest
    • 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.