import org.apache.mina.core.session.DummySession; //导入依赖的package包/类
protected void testFrames ( final String resourceName, final Frame... expectedFrames ) throws Exception
{
    final FrameDecoder decoder = new FrameDecoder ();
    final MockProtocolDecoderOutput out = new MockProtocolDecoderOutput ();
    final DummySession session = new DummySession ();

    session.setTransportMetadata ( new DefaultTransportMetadata ( "eclipse.scada", "test", false, true, SocketAddress.class, IoSessionConfig.class, Object.class ) );

    for ( final IoBuffer data : BufferLoader.loadBuffersFromResource ( FrameDecoderTest.class, resourceName ) )
    {
        System.out.println ( "Pushing data packet - " + data.getHexDump () );
        decoder.decode ( session, data, out );
    }

    out.assertMessages ( expectedFrames );
}
 

import org.apache.mina.core.session.DummySession; //导入依赖的package包/类
private <R extends Response> R retrySync(Request aRequest) throws Exception {
    RequestEnvelope requestEnv = new RequestEnvelope(aRequest, null, null, sessionTicket, null);
    Logger.getLogger(PlatypusPlatypusConnection.class.getName()).log(Level.FINE, "{0} is connecting to {1}:{2}.", new Object[]{Thread.currentThread().getName(), host, port});
    if (!syncSocket.isConnected()) {
        syncSocket.connect(new InetSocketAddress(host, port));
    }
    Logger.getLogger(PlatypusPlatypusConnection.class.getName()).log(Level.FINE, "{0} is connected to {1}:{2}.", new Object[]{Thread.currentThread().getName(), host, port});
    SyncProtocolEncoderOutput requestOut = new SyncProtocolEncoderOutput();
    syncEncoder.encode(null, requestEnv, requestOut);
    Object oFiltered = requestOut.getFiltered();
    OutputStream os = syncSocket.getOutputStream();
    IoBuffer toWrite = (IoBuffer) oFiltered;
    os.write(toWrite.array());
    byte[] readBuffer = new byte[1024 * 16];
    ByteArrayOutputStream accumulated = new ByteArrayOutputStream();
    InputStream is = syncSocket.getInputStream();
    int read = 0;
    while (read > -1) {
        read = is.read(readBuffer);
        accumulated.write(readBuffer, 0, read);
        SyncProtocolDecoderOutput responseOut = new SyncProtocolDecoderOutput();
        IoSession session = new DummySession();
        session.setAttribute(RequestEnvelope.class.getSimpleName(), requestEnv);
        if (syncDecoder.doDecode(session, IoBuffer.wrap(accumulated.toByteArray()), responseOut)) {
            sessionTicket = requestEnv.ticket;
            return (R) responseOut.getFiltered();
        }
    }
    throw new Exception("No response was recieved via platypus protocol");
}
 

import org.apache.mina.core.session.DummySession; //导入依赖的package包/类
@Before
public void setUp() throws InterruptedException {
    connMsg = new ConnectMessage();
    connMsg.setProcotolVersion((byte) 0x03);

    m_minaSession = new DummySession();
    
    m_session = new MinaChannel(m_minaSession);

    m_minaSession.getFilterChain().addFirst("MessageCatcher", new IoFilterAdapter() {

        @Override
        public void filterWrite(IoFilter.NextFilter nextFilter, IoSession session,
                                WriteRequest writeRequest) throws Exception {
            try {
                m_receivedMessage = (AbstractMessage) writeRequest.getMessage();
                if (m_receivedMessage instanceof ConnAckMessage) {
                    ConnAckMessage buf = (ConnAckMessage) m_receivedMessage;
                    m_returnCode = buf.getReturnCode();
                }
            } catch (Exception ex) {
                throw new AssertionError("Wrong return code");
            }
        }
    });

    //sleep to let the messaging batch processor to process the initEvent
    Thread.sleep(300);
    
    m_storageService = new MemoryStorageService();
    //m_storageService.initStore();

    subscriptions = new SubscriptionsStore();
    subscriptions.init(m_storageService);
    m_processor = new ProtocolProcessor();
    m_processor.init(subscriptions, m_storageService);
}
 

import org.apache.mina.core.session.DummySession; //导入依赖的package包/类
/** Constructs a new RTMPTConnection */
RTMPTConnection() {
    super(IConnection.Type.POLLING.name().toLowerCase());
    // create a DummySession for the HTTP-based connection to allow our Mina based system happy
    ioSession = new DummySession();
    ioSession.setAttribute(RTMPConnection.RTMP_SESSION_ID, sessionId);
}
 

import org.apache.mina.core.session.DummySession; //导入依赖的package包/类
/**
 * Creates a DummySession for this HTTP-based connection to allow our Mina based system happy.
 * 
 * @return session
 */
protected IoSession getSession() {
	IoSession session = new DummySession();
	session.setAttribute(RTMPConnection.RTMP_CONNECTION_KEY, this);
	session.setAttribute(ProtocolState.SESSION_KEY, getState());
	return session;
}