Examples of Console


Examples of org.apache.qpid.qmf2.console.Console

        try
        {
            System.out.println("** Starting AgentSubscriptionTestConsole used to test subscription behaviour **");
               
            Connection connection = ConnectionHelper.createConnection(url, "{reconnect: true}");
            _console = new Console(this);
            _console.addConnection(connection);

            // Wait until the gizmo Agent has been discovered
            _gizmo = _console.findAgent("gizmo");
            if (_gizmo == null)
View Full Code Here

Examples of org.apache.qpid.qmf2.console.Console

            System.out.println("but attaching jconsole shows memory consumption. It *looks* like it's leaking");
            System.out.println("memory, but it turns out to be due to the use of a SoftReference in Qpid's");
            System.out.println("setReplyTo() method on JMSMessage. Consumption *eventually* flattens out...");
               
            Connection connection = ConnectionHelper.createConnection(url, "{reconnect: true}");
            _console = new Console(this);
            _console.addConnection(connection);

            // First we create a large number of queues using the QMF2 create method on the broker object
            List<QmfConsoleData> brokers = _console.getObjects("org.apache.qpid.broker", "broker");
            if (brokers.isEmpty())
View Full Code Here

Examples of org.apache.qpid.qmf2.console.Console

        _url = url;
        _filter = filter;
        try
        {
            Connection connection = ConnectionHelper.createConnection(url, connectionOptions);       
            _console = new Console(this);
            _console.addConnection(connection);

            // Wait until the broker Agent has been discovered
            _broker = _console.findAgent("broker");
            if (_broker != null)
View Full Code Here

Examples of org.apache.qpid.qmf2.console.Console

                    extraArguments.add(opt[1]);
                }
            }

            Connection connection = ConnectionHelper.createConnection(_host, "{reconnect: true}");       
            _console = new Console();
            _console.disableEvents(); // Optimisation, as we're only doing getObjects() calls.
            _console.addConnection(connection);
            List<QmfConsoleData> brokers = _console.getObjects("org.apache.qpid.broker", "broker");
            if (brokers.isEmpty())
            {
View Full Code Here

Examples of org.apache.qpid.qmf2.console.Console

        _filter = filter;
        _purge = purge;
        try
        {
            Connection connection = ConnectionHelper.createConnection(url, connectionOptions);       
            _console = new Console(this);
            _console.addConnection(connection);
            updateQueueCache();
        }
        catch (QmfException qmfe)
        {
View Full Code Here

Examples of org.apache.qpid.qmf2.console.Console

        System.out.println("Connecting to " + url);
        _url = url;
        try
        {
            Connection connection = ConnectionHelper.createConnection(url, connectionOptions);       
            _console = new Console(this);
            _console.addConnection(connection);
        }
        catch (QmfException qmfe)
        {
            System.err.println ("QmfException " + qmfe.getMessage() + " caught in QpidPrintEvents constructor");
View Full Code Here

Examples of org.apache.qpid.qmf2.console.Console

                    final String id, final String agentName, final String command, final String args)
    {
        try
        {
            Connection connection = ConnectionHelper.createConnection(url, connectionOptions);       
            _console = new Console();
            _console.addConnection(connection);

            // Find the specified Agent
            Agent agent = _console.findAgent(agentName);
            if (agent == null)
View Full Code Here

Examples of org.apache.qpid.qmf2.console.Console

        _url = url;
        _whitelist = whitelist;
        try
        {
            Connection connection = ConnectionHelper.createConnection(url, connectionOptions);       
            _console = new Console(this);
            _console.addConnection(connection);
            checkExistingSubscriptions();
        }
        catch (QmfException qmfe)
        {
View Full Code Here

Examples of org.apache.qpid.qmf2.console.Console

    public ConnectionLogger(final String url, final String connectionOptions, final boolean logQueues)
    {
        try
        {
            Connection connection = ConnectionHelper.createConnection(url, connectionOptions);       
            _console = new Console(this);
            _console.addConnection(connection);
            _logQueues = logQueues;
            System.out.println("Hit Return to exit");
            logConnectionInformation();
        }
View Full Code Here

Examples of org.apache.qpid.qmf2.console.Console

                // if there was an intention to retrieve work items, but in a fairly general REST API we can't guarantee
                // that clients will. ConsoleLease acts to make the WorkQueue "circular" by deleting items from the
                // front of the WorkQueue if it exceeds a particular size.
                if (_disableEvents)
                {
                    _console = new Console(_name, null, null, null);
                    _console.disableEvents();
                }
                else
                {
                    BlockingNotifier notifier = new BlockingNotifier();
                    _console = new Console(_name, null, notifier, null);
                }
                _console.addConnection(_connection);
                _connected = true;
                _expireCount = UNUSED_THRESHOLD;
                notifyAll();
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.