Examples of TransportStatusEvent

Examples of org.activemq.transport.TransportStatusEvent

526
527
528
529
530
531
532
    protected void initializeStreams() throws IOException{
        BufferedInputStream buffIn = new BufferedInputStream(socket.getInputStream(),8192);
        this.dataIn = new DataInputStream(buffIn);
        TcpBufferedOutputStream buffOut = new TcpBufferedOutputStream(socket.getOutputStream(),8192);
        this.dataOut = new DataOutputStream(buffOut);
        fireStatusEvent(new TransportStatusEvent(this,TransportStatusEvent.CONNECTED));
    }
View Full Code Here

Examples of org.codehaus.activemq.transport.TransportStatusEvent

153
154
155
156
157
158
159
160
161
162
                    log.warn("Peer closed connection", ex);
                }
                else {
                    onAsyncException(JMSExceptionHelper.newJMSException("Error reading socket: " + ex, ex));
                }
                fireStatusEvent(new TransportStatusEvent(this,TransportStatusEvent.DISCONNECTED));
            }
            stop();
        }
    }
View Full Code Here

Examples of org.codehaus.activemq.transport.TransportStatusEvent

475
476
477
478
479
480
481
482
483
484
                    }
                }
                else {
                    onAsyncException(JMSExceptionHelper.newJMSException("Error reading socket: " + ex, ex));
                }
                fireStatusEvent(new TransportStatusEvent(this,TransportStatusEvent.DISCONNECTED));
            }
            stop();
        }
    }
View Full Code Here

Examples of org.codehaus.activemq.transport.TransportStatusEvent

503
504
505
506
507
508
509
    protected void initializeStreams() throws IOException{
        BufferedInputStream buffIn = new BufferedInputStream(socket.getInputStream(),8192);
        this.dataIn = new DataInputStream(buffIn);
        TcpBufferedOutputStream buffOut = new TcpBufferedOutputStream(socket.getOutputStream(),8192);
        this.dataOut = new DataOutputStream(buffOut);
        fireStatusEvent(new TransportStatusEvent(this,TransportStatusEvent.CONNECTED));
    }
View Full Code Here

Examples of org.codehaus.activemq.transport.TransportStatusEvent

458
459
460
461
462
463
464
465
466
467
                    log.warn("Peer closed connection", ex);
                }
                else {
                    onAsyncException(JMSExceptionHelper.newJMSException("Error reading socket: " + ex, ex));
                }
                fireStatusEvent(new TransportStatusEvent(this,TransportStatusEvent.DISCONNECTED));
            }
            stop();
        }
    }
View Full Code Here

Examples of org.codehaus.activemq.transport.TransportStatusEvent

478
479
480
481
482
483
484
        socket.setTcpNoDelay(isNoDelay());
        BufferedInputStream buffIn = new BufferedInputStream(socket.getInputStream());
        this.dataIn = new DataInputStream(buffIn);
        TcpBufferedOutputStream buffOut = new TcpBufferedOutputStream(socket.getOutputStream());
        this.dataOut = new DataOutputStream(buffOut);
        fireStatusEvent(new TransportStatusEvent(this,TransportStatusEvent.CONNECTED));
    }
View Full Code Here

Examples of org.codehaus.activemq.transport.TransportStatusEvent

132
133
134
135
136
137
138
        log.debug("Forcing disconnect");
        if (socket != null && socket.isConnected()) {
            socket.close();
        }
        setTransportConnected(false);
        fireStatusEvent(new TransportStatusEvent(this,TransportStatusEvent.DISCONNECTED));
    }
View Full Code Here

Examples of org.codehaus.activemq.transport.TransportStatusEvent

151
152
153
154
155
156
157
158
159
160
                    log.warn("Peer closed connection", ex);
                }
                else {
                    onAsyncException(JMSExceptionHelper.newJMSException("Error reading socket: " + ex, ex));
                }
                fireStatusEvent(new TransportStatusEvent(this,TransportStatusEvent.DISCONNECTED));
            }
            stop();
        }
    }
View Full Code Here

Examples of org.codehaus.activemq.transport.TransportStatusEvent

130
131
132
133
134
135
136
    log.debug("Forcing disconnect");
    if (socket != null && socket.isConnected()) {
        socket.close();
    }
    setTransportConnected(false);
    fireStatusEvent(new TransportStatusEvent(TransportStatusEvent.DISCONNECTED));
}
View Full Code Here

Examples of org.codehaus.activemq.transport.TransportStatusEvent

435
436
437
438
439
440
441
442
443
444
445
        }
    }

    private void doClose(Exception ex) {
        if (!closed.get()) {
          fireStatusEvent(new TransportStatusEvent(TransportStatusEvent.DISCONNECTED));
            setPendingStop(true);
            onAsyncException(JMSExceptionHelper.newJMSException("Error reading socket: " + ex, ex));
            stop();
        }
    }
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.