Examples of registerConnection()

Examples of com.sun.messaging.jmq.jmsserver.management.agent.Agent.registerConnection()

244
245
246
247
248
249
250
251
252
253
254
                  Globals.getBrokerResources().getKString(
                  BrokerResources.M_AUTH_FAIL_CLOSE));
        } else  {
            Agent agent = Globals.getAgent();
            if (agent != null)  {
                agent.registerConnection(con.getConnectionUID().longValue());
                agent.notifyConnectionOpen(con.getConnectionUID().longValue());
            }
  }

        return true;
View Full Code Here

Examples of com.sun.messaging.jmq.jmsserver.management.agent.Agent.registerConnection()

350
351
352
353
354
355
356
357
358
359
360
      throw new SecurityException(errStr);
  }

  Agent agent = Globals.getAgent();
  if (agent != null)  {
      agent.registerConnection(con.getConnectionUID().longValue());
      agent.notifyConnectionOpen(con.getConnectionUID().longValue());
  }

  /*
  System.err.println("#### CREATE DIRECT CXN: returning: " + con);
View Full Code Here

Examples of org.apache.ojb.otm.core.Transaction.registerConnection()

61
62
63
64
65
66
67
68
69
70
71
        {
            tx = new Transaction();
            _transactionMap.put(connection, tx);
        }
        // ensure that this connection is registered into this transaction
        tx.registerConnection(connection);
        return tx;
    }


    /**
 
View Full Code Here

Examples of org.apache.ojb.otm.core.Transaction.registerConnection()

76
77
78
79
80
81
82
83
84
85
86
            tx = new Transaction();
            _transactionMap.put(jtaTx, tx);
        }

        // ensure that this connection is registered into this transaction
        tx.registerConnection(baseConnection);
        return tx;
  }

    /**
     * @see org.apache.ojb.otm.transaction.TransactionFactory#acquireConnection
View Full Code Here

Examples of org.apache.ojb.otm.core.Transaction.registerConnection()

66
67
68
69
70
71
72
73
74
75
76
        try
        {
            tx = _kit.getTransaction(conn1);
            tx.begin();

            tx.registerConnection(conn2);

            example = (Article) conn1.getObjectByIdentity(
                    new Identity(Article.class, Article.class,
                                 new Object[]{new Integer(77779)}));
            if (example == null)
View Full Code Here

Examples of org.apache.ojb.otm.core.Transaction.registerConnection()

64
65
66
67
68
69
70
71
72
73
74
        try
        {
            tx = _kit.getTransaction(conn1);
            tx.begin();

            tx.registerConnection(conn2);

            example = (Article) conn1.getObjectByIdentity(
                    new Identity(Article.class, Article.class,
                                 new Object[]{new Integer(77779)}));
            if (example == null)
View Full Code Here

Examples of org.apache.ojb.otm.core.Transaction.registerConnection()

61
62
63
64
65
66
67
68
69
70
71
        {
            tx = new Transaction();
            _transactionMap.put(connection, tx);
        }
        // ensure that this connection is registered into this transaction
        tx.registerConnection(connection);
        return tx;
    }


    /**
 
View Full Code Here

Examples of org.apache.ojb.otm.core.Transaction.registerConnection()

76
77
78
79
80
81
82
83
84
85
86
            tx = new Transaction();
            _transactionMap.put(jtaTx, tx);
        }

        // ensure that this connection is registered into this transaction
        tx.registerConnection(baseConnection);
        return tx;
  }

    /**
     * @see org.apache.ojb.otm.transaction.TransactionFactory#acquireConnection
View Full Code Here

Examples of org.apache.ojb.otm.core.Transaction.registerConnection()

64
65
66
67
68
69
70
71
72
73
74
        try
        {
            tx = _kit.getTransaction(conn1);
            tx.begin();

            tx.registerConnection(conn2);

            example = (Article) conn1.getObjectByIdentity(
                    new Identity(Article.class, Article.class,
                                 new Object[]{new Integer(77779)}));
            if (example == null)
View Full Code Here

Examples of org.jboss.ejb.client.EJBClientContext.registerConnection()

50
51
52
53
54
55
56
57
58
59
60
            // open a connection
            final IoFuture<Connection> futureConnection = endpoint.connect(new URI(hostUrl), OptionMap.create(Options.SASL_POLICY_NOANONYMOUS, Boolean.FALSE, Options.SASL_POLICY_NOPLAINTEXT, Boolean.FALSE), callbackHandler);
            connection = IoFutureHelper.get(futureConnection, 30L, TimeUnit.SECONDS);

            final EJBClientContext ejbClientContext = EJBClientContext.create();
            ejbClientContext.registerConnection(connection);

            this.clientContext = ejbClientContext;
        } catch (IOException e) {
            throw new RuntimeException(e);
        } catch (URISyntaxException e) {
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.