Examples of SessionID

com.odiago.flumebase.server.SessionId
Identifier for a user session connected to the remote server.
com.persistit.SessionId

Identity key for a session. Normally there is one session per thread, but applications that need to maintain session context across multiple network requests serviced on different threads can access and carefully modify their session contexts using SessionID. See {@link Persistit#getSessionId()} and{@link Persistit#setSessionId(SessionId)}.

A SessionId instance holds a reference to the Thread currently associated with it; initially this this the thread that created the SessionId. The setSessionId method reassigns the thread field. The {@link #isAlive()} method indicates whether the associated thread isalive. The {@link Persistit#cleanup()} method cleans up all transactionresources for SessionId instances whose threads are no longer alive.

A session is used to maintain state, including the {@link Transaction}context and map of cached {@link Exchange} maintained by{@link Persistit#getExchange(String,String,boolean)}. Therefore care must be taken to limit the maximum number of SessionId instances created during the lifetime of a Persistit instance and to manage them appropriately.
@author peter
io.fabric8.gateway.handlers.detecting.protocol.openwire.command.SessionId
@openwire :marshaller code="121"
org.apache.activemq.apollo.openwire.command.SessionId
@openwire :marshaller code="121"
org.apache.activemq.command.SessionId
@openwire :marshaller code="121" @version $Revision$
org.apache.helix.api.id.SessionId
org.jboss.ejb.client.SessionID
org.openqa.selenium.remote.SessionId
org.owasp.webscarab.plugin.sessionid.SessionID
@author rdawes
quickfix.SessionID

Examples of quickfix.SessionID

        if (dictionaryValue instanceof DataDictionary) {
            dataDictionary = (DataDictionary) dictionaryValue;
        } else if (dictionaryValue instanceof String) {
            dataDictionary = new DataDictionary((String) dictionaryValue);
        } else {
            SessionID sessionID = (SessionID) exchange.getIn().getHeader(QuickfixjEndpoint.SESSION_ID_KEY);
            Session session = Session.lookupSession(sessionID);
            dataDictionary = session != null ? session.getDataDictionary() : null;
        }


        return dataDictionary;

View Full Code Here

Examples of quickfix.SessionID


        contextClassLoader = Thread.currentThread().getContextClassLoader();
        ClassLoader testClassLoader = new URLClassLoader(urls, contextClassLoader);
        Thread.currentThread().setContextClassLoader(testClassLoader);


        sessionID = new SessionID(FixVersions.BEGINSTRING_FIX44, "FOO", "BAR");


        settings = new SessionSettings();
        settings.setString(Acceptor.SETTING_SOCKET_ACCEPT_PROTOCOL, TransportType.VM_PIPE.toString());
        settings.setString(Initiator.SETTING_SOCKET_CONNECT_PROTOCOL, TransportType.VM_PIPE.toString());
        settings.setBool(Session.SETTING_USE_DATA_DICTIONARY, false);

View Full Code Here

Examples of quickfix.SessionID

    @Test
    public void minimalInitiatorAndAcceptor() throws Exception {
        settings.setString(sessionID, SessionFactory.SETTING_CONNECTION_TYPE, SessionFactory.ACCEPTOR_CONNECTION_TYPE);
        settings.setLong(sessionID, Acceptor.SETTING_SOCKET_ACCEPT_PORT, 1234);


        SessionID initiatorSessionID = new SessionID(FixVersions.BEGINSTRING_FIX44, "FARGLE", "BARGLE");
        settings.setString(initiatorSessionID, SessionFactory.SETTING_CONNECTION_TYPE, SessionFactory.INITIATOR_CONNECTION_TYPE);
        TestSupport.setSessionID(settings, initiatorSessionID);


        writeSettings();

View Full Code Here

Examples of quickfix.SessionID

    }


    @Test
    @Ignore("The session events may arrive out of order, so the test code must be refactored to cater for that - in doLogonEventsTest")
    public void sessionEvents() throws Exception {
        SessionID acceptorSessionID = new SessionID(FixVersions.BEGINSTRING_FIX42, "MARKET", "TRADER");
        SessionID initiatorSessionID = new SessionID(FixVersions.BEGINSTRING_FIX42, "TRADER", "MARKET");


        quickfixjEngine = new QuickfixjEngine("quickfix:test", "examples/inprocess.cfg", false);


        doLogonEventsTest(acceptorSessionID, initiatorSessionID, quickfixjEngine);

View Full Code Here

Examples of quickfix.SessionID

        return new ClassPathXmlApplicationContext("org/apache/camel/component/quickfixj/QuickfixjSpringTest-context.xml");
    }


    @Test
    public void configureInSpring() throws Exception {
        SessionID sessionID = new SessionID("FIX.4.2:INITIATOR->ACCEPTOR");
        QuickfixjConfiguration configuration = context.getRegistry().lookup("quickfixjConfiguration", QuickfixjConfiguration.class);


        SessionSettings springSessionSettings = configuration.createSessionSettings();
        Properties sessionProperties = springSessionSettings.getSessionProperties(sessionID, true);

View Full Code Here

Examples of quickfix.SessionID

    public void removeListener(QuickfixjMessageListener listener) {
        listeners.remove(listener);
    }
    
    public void execute(final Message message) throws FieldNotFound, UnsupportedMessageType, IncorrectTagValue {
        final SessionID sessionID = MessageUtils.getSessionID(message);


        try {
            if (message instanceof quickfix.fix40.NewOrderSingle) {
                onMessage((quickfix.fix40.NewOrderSingle) message, sessionID);
            } else if (message instanceof quickfix.fix41.NewOrderSingle) {

View Full Code Here

0 1 2 3 4 5

TOP

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.