Examples of SessionSettings

org.apache.wicket.jmx.wrapper.SessionSettings
Exposes Application related functionality for JMX. @author eelcohillenius
org.apache.wicket.settings.def.SessionSettings
@author Jonathan Locke @author Chris Turner @author Eelco Hillenius @author Juergen Donnerstag @author Johan Compagner @author Igor Vaynberg (ivaynberg) @author Martijn Dashorst @author James Carman
quickfix.SessionSettings

Examples of quickfix.SessionSettings

        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);
        TestSupport.setSessionID(settings, sessionID);
    }

View Full Code Here

Examples of quickfix.SessionSettings

public class QuickfixjSettingsFactory implements FactoryBean<SessionSettings> {
    private Map<Object, Object> defaultSettings = Collections.emptyMap();
    private Map<SessionID, Map<Object, Object>> sessionSettings = Collections.emptyMap();


    public SessionSettings getObject() throws Exception {
        SessionSettings settings = new SessionSettings();
        settings.set(new Dictionary("defaults", defaultSettings));
        for (Map.Entry<SessionID, Map<Object, Object>> sessionSetting : sessionSettings.entrySet()) {
            settings.set(sessionSetting.getKey(), new Dictionary("session", sessionSetting.getValue()));
        }
        return settings;
    }

View Full Code Here

Examples of quickfix.SessionSettings

        SessionID sessionID = new SessionID("FIX.4.2:SENDER->TARGET");
        sessionSettings.put(sessionID, session1Settings);


        factory.setSessionSettings(sessionSettings);


        SessionSettings settings = factory.getObject();
        Properties sessionProperties = settings.getSessionProperties(sessionID, true);


        Assert.assertThat(sessionProperties.get("value1").toString(), CoreMatchers.is("10"));
        Assert.assertThat(sessionProperties.get("value2").toString(), CoreMatchers.is("2"));
        Assert.assertThat(sessionProperties.get("value3").toString(), CoreMatchers.is("30"));
    }

View Full Code Here

Examples of quickfix.SessionSettings

        tempdir = settingsFile.getParentFile();
        URL[] urls = new URL[] {tempdir.toURI().toURL()};
        
        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);
        setSessionID(settings, sessionID);

View Full Code Here

Examples of quickfix.SessionSettings

    public void messagePublication() throws Exception {
        setUpComponent();


        // Create settings file with both acceptor and initiator
        
        SessionSettings 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);
        
        SessionID acceptorSessionID =  new SessionID(FixVersions.BEGINSTRING_FIX44, "ACCEPTOR", "INITIATOR");
        settings.setString(acceptorSessionID, SessionFactory.SETTING_CONNECTION_TYPE, SessionFactory.ACCEPTOR_CONNECTION_TYPE);
        settings.setLong(acceptorSessionID, Acceptor.SETTING_SOCKET_ACCEPT_PORT, 1234);
        setSessionID(settings, acceptorSessionID);
        
        SessionID initiatorSessionID = new SessionID(FixVersions.BEGINSTRING_FIX44, "INITIATOR", "ACCEPTOR");
        settings.setString(initiatorSessionID, SessionFactory.SETTING_CONNECTION_TYPE, SessionFactory.INITIATOR_CONNECTION_TYPE);
        settings.setLong(initiatorSessionID, Initiator.SETTING_SOCKET_CONNECT_PORT, 1234);
        settings.setLong(initiatorSessionID, Initiator.SETTING_RECONNECT_INTERVAL, 1);
        setSessionID(settings, initiatorSessionID);


        writeSettings(settings);
        
        Endpoint endpoint = component.createEndpoint(getEndpointUri(settingsFile.getName(), null));

View Full Code Here

Examples of quickfix.SessionSettings

    private static SessionSettings loadSettings(String settingsResourceName) throws ConfigError {
        InputStream inputStream = ObjectHelper.loadResourceAsStream(settingsResourceName);
        if (inputStream == null) {
            throw new IllegalArgumentException("Could not load " + settingsResourceName);
        }
        return new SessionSettings(inputStream);
    }

View Full Code Here

Examples of quickfix.SessionSettings


            if (endpoint == null) {
                engine = engines.get(remaining);
                if (engine == null) {
                    LOG.info("Creating QuickFIX/J engine using settings: " + remaining);
                    SessionSettings settings = engineSettings.get(remaining);
                    if (settings != null) {
                        engine = new QuickfixjEngine(uri, settings, forcedShutdown, messageStoreFactory, logFactory, messageFactory);
                    } else {
                        engine = new QuickfixjEngine(uri, remaining, forcedShutdown, messageStoreFactory, logFactory, messageFactory);
                    }

View Full Code Here

Examples of quickfix.SessionSettings

        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);
        TestSupport.setSessionID(settings, sessionID);
    }

View Full Code Here

Examples of quickfix.SessionSettings

    @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);


        Assert.assertThat(sessionProperties.get("ConnectionType").toString(), CoreMatchers.is("initiator"));
        Assert.assertThat(sessionProperties.get("SocketConnectProtocol").toString(), CoreMatchers.is("VM_PIPE"));


        QuickfixjComponent component = context.getComponent("quickfix", QuickfixjComponent.class);

View Full Code Here

Examples of quickfix.SessionSettings

        tempdir = settingsFile.getParentFile();
        URL[] urls = new URL[] {tempdir.toURI().toURL()};
        
        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);
        setSessionID(settings, sessionID);

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.