Package javax.resource.spi

Examples of javax.resource.spi.ConnectionEvent

380
381
382
383
384
385
386
387
388
389
390
        return this.mcf;
    }

    void fireBeginEvent()
    {
        ConnectionEvent event = new ConnectionEvent(MuleManagedConnection.this,
            ConnectionEvent.LOCAL_TRANSACTION_STARTED);
        Iterator iterator = listeners.iterator();
        while (iterator.hasNext())
        {
            ConnectionEventListener l = (ConnectionEventListener)iterator.next();
View Full Code Here
392
393
394
395
396
397
398
399
400
401
402
        }
    }

    void fireCommitEvent()
    {
        ConnectionEvent event = new ConnectionEvent(MuleManagedConnection.this,
            ConnectionEvent.LOCAL_TRANSACTION_COMMITTED);
        Iterator iterator = listeners.iterator();
        while (iterator.hasNext())
        {
            ConnectionEventListener l = (ConnectionEventListener)iterator.next();
View Full Code Here
404
405
406
407
408
409
410
411
412
413
414
        }
    }

    void fireRollbackEvent()
    {
        ConnectionEvent event = new ConnectionEvent(MuleManagedConnection.this,
            ConnectionEvent.LOCAL_TRANSACTION_ROLLEDBACK);
        Iterator iterator = listeners.iterator();
        while (iterator.hasNext())
        {
            ConnectionEventListener l = (ConnectionEventListener)iterator.next();
View Full Code Here
416
417
418
419
420
421
422
423
424
425
426
427
428
        }
    }

    void fireCloseEvent(MuleConnection connection)
    {
        ConnectionEvent event = new ConnectionEvent(MuleManagedConnection.this,
            ConnectionEvent.CONNECTION_CLOSED);
        event.setConnectionHandle(connection);

        Iterator iterator = listeners.iterator();
        while (iterator.hasNext())
        {
            ConnectionEventListener l = (ConnectionEventListener)iterator.next();
View Full Code Here
430
431
432
433
434
435
436
437
438
439
440
        }
    }

    void fireErrorOccurredEvent(Exception error)
    {
        ConnectionEvent event = new ConnectionEvent(MuleManagedConnection.this,
            ConnectionEvent.CONNECTION_ERROR_OCCURRED, error);
        Iterator iterator = listeners.iterator();
        while (iterator.hasNext())
        {
            ConnectionEventListener l = (ConnectionEventListener)iterator.next();
View Full Code Here
346
347
348
349
350
351
352
353
354
355
356
357
        //    return;
        //see ConnectionEventListeners 6.5.6.1
        //the application server is listening to these events

        //only notify closed, if all handles are closed
        ConnectionEvent ce = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED, null);
        ce.setConnectionHandle(handle);
        Collection<ConnectionEventListener> localCels = null;
        synchronized (cels)
        {
            localCels = new ArrayList(cels);
        }
View Full Code Here
140
141
142
143
144
145
146
147
148
149
150
    public Connection getPhysicalConnection() {
        return physicalConnection;
    }
   
    private void fireBeginEvent() {
        ConnectionEvent event = new ConnectionEvent(ActiveMQManagedConnection.this,
                ConnectionEvent.LOCAL_TRANSACTION_STARTED);
        Iterator iterator = listeners.iterator();
        while (iterator.hasNext()) {
            ConnectionEventListener l = (ConnectionEventListener) iterator.next();
            l.localTransactionStarted(event);
View Full Code Here
150
151
152
153
154
155
156
157
158
159
160
            l.localTransactionStarted(event);
        }
    }

    private void fireCommitEvent() {
        ConnectionEvent event = new ConnectionEvent(ActiveMQManagedConnection.this,
                ConnectionEvent.LOCAL_TRANSACTION_COMMITTED);
        Iterator iterator = listeners.iterator();
        while (iterator.hasNext()) {
            ConnectionEventListener l = (ConnectionEventListener) iterator.next();
            l.localTransactionCommitted(event);
View Full Code Here
160
161
162
163
164
165
166
167
168
169
170
            l.localTransactionCommitted(event);
        }
    }

    private void fireRollbackEvent() {
        ConnectionEvent event = new ConnectionEvent(ActiveMQManagedConnection.this,
                ConnectionEvent.LOCAL_TRANSACTION_ROLLEDBACK);
        Iterator iterator = listeners.iterator();
        while (iterator.hasNext()) {
            ConnectionEventListener l = (ConnectionEventListener) iterator.next();
            l.localTransactionRolledback(event);
View Full Code Here
170
171
172
173
174
175
176
177
178
179
180
181
182
            l.localTransactionRolledback(event);
        }
    }

    private void fireCloseEvent(ManagedConnectionProxy proxy) {
        ConnectionEvent event = new ConnectionEvent(ActiveMQManagedConnection.this,
                ConnectionEvent.CONNECTION_CLOSED);
        event.setConnectionHandle(proxy);
       
        Iterator iterator = listeners.iterator();
        while (iterator.hasNext()) {
            ConnectionEventListener l = (ConnectionEventListener) iterator.next();
            l.connectionClosed(event);
View Full Code Here
TOP

Related Classes of javax.resource.spi.ConnectionEvent

  • com.caucho.jms.jca.ManagedSessionImpl
  • com.caucho.sql.ManagedConnectionImpl
  • com.hazelcast.jca.ManagedConnectionImpl
  • com.ibm.j2g.jca.connector.impl.FileRetrieverManagedConnection
  • com.sleepycat.je.jca.ra.JELocalTransaction
  • com.sleepycat.je.jca.ra.JEManagedConnection
  • com.sun.connector.blackbox.JdbcConnectionEventListener
  • com.sun.connector.cciblackbox.CciConnectionEventListener
  • com.sun.gjc.spi.ManagedConnection
  • com.sun.gjc.spi.ManagedConnectionImpl
    • 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.