Java StreamID类的典型用法和代码示例

本文整理汇总了Java中org.jivesoftware.openfire.StreamID类的典型用法代码示例。如果您正苦于以下问题：Java StreamID类的具体用法？Java StreamID怎么用？Java StreamID使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

StreamID类属于org.jivesoftware.openfire包，在下文中一共展示了StreamID类的27个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: attemptDialbackOverTLS

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
private static LocalOutgoingServerSession attemptDialbackOverTLS(Connection connection, XMPPPacketReader reader, String localDomain, String remoteDomain, String id) {
    final Logger log = LoggerFactory.getLogger( Log.getName() + "[Dialback over TLS for: " + localDomain + " to: " + remoteDomain + " (Stream ID: " + id + ")]" );

    if (ServerDialback.isEnabled() || ServerDialback.isEnabledForSelfSigned()) {
        log.debug("Trying to connecting using dialback over TLS.");
        ServerDialback method = new ServerDialback(connection, localDomain);
        OutgoingServerSocketReader newSocketReader = new OutgoingServerSocketReader(reader);
        if (method.authenticateDomain(newSocketReader, localDomain, remoteDomain, id)) {
            log.debug("Dialback over TLS was successful.");
            StreamID streamID = new BasicStreamIDFactory().createStreamID(id);
            LocalOutgoingServerSession session = new LocalOutgoingServerSession(localDomain, connection, newSocketReader, streamID);
            connection.init(session);
            // Set the hostname as the address of the session
            session.setAddress(new JID(null, remoteDomain, null));
            return session;
        }
        else {
            log.debug("Dialback over TLS failed");
            return null;
        }
    }
    else {
        log.debug("Skipping server dialback attempt as it has been disabled by local configuration.");
        return null;
    }    	
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:27，
代码来源:LocalOutgoingServerSession.java

示例2: getMultiplexerSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
/**
 * Returns a {@link ConnectionMultiplexerSession} for the specified connection manager
 * domain or <tt>null</tt> if none was found. If a StreamID is passed in, the same connection
 * will always be used for that StreamID. Otherwise, if the connection manager has many
 * connections established with the server then one of them will be selected randomly.
 *
 * @param connectionManagerDomain the domain of the connection manager to get a session.
 * @param streamID if provided, the same connection will always be used for a given streamID
 * @return a session to the specified connection manager domain or null if none was found.
 */
public ConnectionMultiplexerSession getMultiplexerSession(String connectionManagerDomain,StreamID streamID) {
    List<ConnectionMultiplexerSession> sessions =
            sessionManager.getConnectionMultiplexerSessions(connectionManagerDomain);
    if (sessions.isEmpty()) {
        return null;
    }
    else if (sessions.size() == 1) {
        return sessions.get(0);
    }
    else if (streamID != null) {
        // Always use the same connection for a given streamID
        int connectionIndex = Math.abs(streamID.hashCode()) % sessions.size();
        return sessions.get(connectionIndex);
    } else {
        // Pick a random session so we can distribute traffic evenly
        return sessions.get(randGen.nextInt(sessions.size()));
    }
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:29，
代码来源:ConnectionMultiplexerManager.java

示例3: deliver

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
/**
 * Delivers the packet to the Connection Manager that in turn will forward it to the
 * target user. Connection Managers may have one or many connections to the server so
 * just get any connection to the Connection Manager (uses a random) and use it.<p>
 *
 * If the packet to send does not have a TO attribute then wrap the packet with a
 * special IQ packet. The wrapper IQ packet will be sent to the Connection Manager
 * and the stream ID of this Client Session will be used for identifying that the wrapped
 * packet must be sent to the connected user. Since some packets can be exchanged before
 * the user has a binded JID we need to use the stream ID as the unique identifier.
 *
 * @param packet the packet to send to the user.
 */
@Override
public void deliver(Packet packet) {
    StreamID streamID = session.getStreamID();
    ConnectionMultiplexerSession multiplexerSession =
            multiplexerManager.getMultiplexerSession(connectionManagerName,streamID);
    if (multiplexerSession != null) {
        // Wrap packet so that the connection manager can figure out the target session
        Route wrapper = new Route(streamID);
        wrapper.setFrom(serverName);
        wrapper.setTo(connectionManagerName);
        wrapper.setChildElement(packet.getElement().createCopy());
        // Deliver wrapper
        multiplexerSession.process(wrapper);
        session.incrementServerPacketCount();
    }
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:30，
代码来源:ClientSessionConnection.java

示例4: deliverRawText

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
/**
 * Delivers the stanza to the Connection Manager that in turn will forward it to the
 * target user. Connection Managers may have one or many connections to the server so
 * just get any connection to the Connection Manager (uses a random) and use it.<p>
 *
 * The stanza to send wrapped with a special IQ packet. The wrapper IQ packet will be
 * sent to the Connection Manager and the stream ID of this Client Session will be used
 * for identifying that the wrapped stanza must be sent to the connected user.
 *
 * @param text the stanza to send to the user.
 */
@Override
public void deliverRawText(String text) {
    StreamID streamID = session.getStreamID();
    ConnectionMultiplexerSession multiplexerSession =
            multiplexerManager.getMultiplexerSession(connectionManagerName,streamID);
    if (multiplexerSession != null) {
        // Wrap packet so that the connection manager can figure out the target session
        StringBuilder sb = new StringBuilder(200 + text.length());
        sb.append("<route from=\"").append(serverName);
        sb.append("\" to=\"").append(connectionManagerName);
        sb.append("\" streamid=\"").append(streamID.getID()).append("\">");
        sb.append(text);
        sb.append("</route>");
        // Deliver the wrapped stanza
        multiplexerSession.deliverRawText(sb.toString());
    }
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:29，
代码来源:ClientSessionConnection.java

示例5: closeVirtualConnection

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
/**
 * If the Connection Manager or the Client requested to close the connection then just do
 * nothing. But if the server originated the request to close the connection then we need
 * to send to the Connection Manager a packet letting him know that the Client Session needs
 * to be terminated.
 */
@Override
public void closeVirtualConnection() {
    // Figure out who requested the connection to be closed
    StreamID streamID = session.getStreamID();
    if (multiplexerManager.getClientSession(connectionManagerName, streamID) == null) {
        // Client or Connection manager requested to close the session
        // Do nothing since it has already been removed and closed
    }
    else {
        ConnectionMultiplexerSession multiplexerSession =
                multiplexerManager.getMultiplexerSession(connectionManagerName,streamID);
        if (multiplexerSession != null) {
            // Server requested to close the client session so let the connection manager
            // know that he has to finish the client session
            IQ closeRequest = new IQ(IQ.Type.set);
            closeRequest.setFrom(serverName);
            closeRequest.setTo(connectionManagerName);
            Element child = closeRequest.setChildElement("session",
                    "http://jabber.org/protocol/connectionmanager");
            child.addAttribute("id", streamID.getID());
            child.addElement("close");
            multiplexerSession.process(closeRequest);
        }
    }
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:32，
代码来源:ClientSessionConnection.java

示例6: attemptDialbackOverTLS

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
private static LocalOutgoingServerSession attemptDialbackOverTLS(Connection connection, XMPPPacketReader reader, String domain, String hostname, String id) {
	final Logger log = LoggerFactory.getLogger(LocalOutgoingServerSession.class.getName()+"['"+hostname+"']");
    if (ServerDialback.isEnabled() || ServerDialback.isEnabledForSelfSigned()) {
        log.debug("Trying to connecting using dialback over TLS.");
        ServerDialback method = new ServerDialback(connection, domain);
        OutgoingServerSocketReader newSocketReader = new OutgoingServerSocketReader(reader);
        if (method.authenticateDomain(newSocketReader, domain, hostname, id)) {
            log.debug("Dialback over TLS was successful.");
            StreamID streamID = new BasicStreamIDFactory().createStreamID(id);
            LocalOutgoingServerSession session = new LocalOutgoingServerSession(domain, connection, newSocketReader, streamID);
            connection.init(session);
            // Set the hostname as the address of the session
            session.setAddress(new JID(null, hostname, null));
            return session;
        }
        else {
            log.debug("Dialback over TLS failed");
            return null;
        }
    }
    else {
        log.debug("Skipping server dialback attempt as it has been disabled by local configuration.");
        return null;
    }    	
}

开发者ID:coodeer，
项目名称:g3server，
代码行数:26，
代码来源:LocalOutgoingServerSession.java

示例7: LocalSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
/**
 * Creates a session with an underlying connection and permission protection.
 *
 * @param serverName domain of the XMPP server where the new session belongs.
 * @param connection The connection we are proxying.
 * @param streamID unique identifier for this session.
 * @param language The language to use for this session.
 */
public LocalSession(String serverName, Connection connection, StreamID streamID, Locale language) {
    if (connection == null) {
        throw new IllegalArgumentException("connection must not be null");
    }
    conn = connection;
    this.streamID = streamID;
    this.serverName = serverName;
    String id = streamID.getID();
    this.address = new JID(null, serverName, id, true);
    this.sessionManager = SessionManager.getInstance();
    this.streamManager = new StreamManager(this);
    this.language = language;
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:22，
代码来源:LocalSession.java

示例8: attemptSASLexternal

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
private static LocalOutgoingServerSession attemptSASLexternal(SocketConnection connection, MXParser xpp, XMPPPacketReader reader, String localDomain, String remoteDomain, String id, StringBuilder openingStream) throws DocumentException, IOException, XmlPullParserException {
    final Logger log = LoggerFactory.getLogger( Log.getName() + "[EXTERNAL SASL for: " + localDomain + " to: " + remoteDomain + " (Stream ID: " + id + ")]" );

    log.debug("Starting EXTERNAL SASL.");
    if (doExternalAuthentication(localDomain, connection, reader)) {
        log.debug("EXTERNAL SASL was successful.");
        // SASL was successful so initiate a new stream
        connection.deliverRawText(openingStream.toString());
        
        // Reset the parser
        //xpp.resetInput();
        //             // Reset the parser to use the new secured reader
        xpp.setInput(new InputStreamReader(connection.getTLSStreamHandler().getInputStream(), StandardCharsets.UTF_8));
        // Skip the opening stream sent by the server
        for (int eventType = xpp.getEventType(); eventType != XmlPullParser.START_TAG;) {
            eventType = xpp.next();
        }

        // SASL authentication was successful so create new OutgoingServerSession
        id = xpp.getAttributeValue("", "id");
        StreamID streamID = new BasicStreamIDFactory().createStreamID(id);
        LocalOutgoingServerSession session = new LocalOutgoingServerSession(localDomain, connection, new OutgoingServerSocketReader(reader), streamID);
        connection.init(session);
        // Set the hostname as the address of the session
        session.setAddress(new JID(null, remoteDomain, null));
        // Set that the session was created using TLS+SASL (no server dialback)
        session.usingServerDialback = false;
        return session;
    }
    else {
        log.debug("EXTERNAL SASL failed.");
        return null;
    }  	
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:35，
代码来源:LocalOutgoingServerSession.java

示例9: createSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
private HttpSession createSession(long rid, InetAddress address, HttpConnection connection, Locale language) throws UnauthorizedException {
    // Create a ClientSession for this user.
    StreamID streamID = SessionManager.getInstance().nextStreamID();
    // Send to the server that a new client session has been created
    HttpSession session = sessionManager.createClientHttpSession(rid, address, streamID, connection, language);
    // Register that the new session is associated with the specified stream ID
    sessionMap.put(streamID.getID(), session);
    session.addSessionCloseListener(sessionListener);
    return session;
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:11，
代码来源:HttpSessionManager.java

示例10: getStreamID

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
/**
 * Return the stream ID that identifies the connection that is actually sending
 * the wrapped stanza.
 *
 * @return the stream ID that identifies the connection that is actually sending
 *         the wrapped stanza.
 */
public StreamID getStreamID() {
    final String value = element.attributeValue( "streamid" );
    if (value == null) {
        return null;
    }
    return BasicStreamIDFactory.createStreamID( value );
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:15，
代码来源:Route.java

示例11: createClientSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
/**
 * Creates a new client session that was established to the specified connection manager.
 * The new session will not be findable through its stream ID.
 *
 * @param connectionManagerDomain the connection manager that is handling the connection
 *        of the session.
 * @param streamID the stream ID created by the connection manager for the new session.
 * @param hostName the address's hostname of the client or null if using old connection manager.
 * @param hostAddress the textual representation of the address of the client or null if using old CM.
 * @return true if a session was created or false if the client should disconnect.
 */
public boolean createClientSession(String connectionManagerDomain, StreamID streamID, String hostName, String hostAddress) {
    Connection connection = new ClientSessionConnection(connectionManagerDomain, hostName, hostAddress);
    // Check if client is allowed to connect from the specified IP address. Ignore the checking if connection
    // manager is old version and is not passing client's address
    byte[] address = null;
    try {
        address = connection.getAddress();
    } catch (UnknownHostException e) {
        // Ignore
    }
    if (address == null || LocalClientSession.isAllowed(connection)) {
        LocalClientSession session =
                SessionManager.getInstance().createClientSession(connection, streamID);
        // Register that this streamID belongs to the specified connection manager
        streamIDs.put(streamID, connectionManagerDomain);
        // Register which sessions are being hosted by the speicifed connection manager
        Map<StreamID, LocalClientSession> sessions = sessionsByManager.get(connectionManagerDomain);
        if (sessions == null) {
            synchronized (connectionManagerDomain.intern()) {
                sessions = sessionsByManager.get(connectionManagerDomain);
                if (sessions == null) {
                    sessions = new ConcurrentHashMap<>();
                    sessionsByManager.put(connectionManagerDomain, sessions);
                }
            }
        }
        sessions.put(streamID, session);
        return true;
    }
    return false;
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:43，
代码来源:ConnectionMultiplexerManager.java

示例12: closeClientSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
/**
 * Closes an existing client session that was established through a connection manager.
 *
 * @param connectionManagerDomain the connection manager that is handling the connection
 *        of the session.
 * @param streamID the stream ID created by the connection manager for the session.
 */
public void closeClientSession(String connectionManagerDomain, StreamID streamID) {
    Map<StreamID, LocalClientSession> sessions = sessionsByManager.get(connectionManagerDomain);
    if (sessions != null) {
        Session session = sessions.remove(streamID);
        if (session != null) {
            // Close the session
            session.close();
        }
    }
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:18，
代码来源:ConnectionMultiplexerManager.java

示例13: multiplexerAvailable

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
/**
 * A connection manager has become available. Clients can now connect to the server through
 * the connection manager.
 *
 * @param connectionManagerName the connection manager that has become available.
 */
public void multiplexerAvailable(String connectionManagerName) {
    // Add a new entry in the list of available managers. Here is where we are going to store
    // which clients were connected through which connection manager
    Map<StreamID, LocalClientSession> sessions = sessionsByManager.get(connectionManagerName);
    if (sessions == null) {
        synchronized (connectionManagerName.intern()) {
            sessions = sessionsByManager.get(connectionManagerName);
            if (sessions == null) {
                sessions = new ConcurrentHashMap<>();
                sessionsByManager.put(connectionManagerName, sessions);
            }
        }
    }
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:21，
代码来源:ConnectionMultiplexerManager.java

示例14: multiplexerUnavailable

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
/**
 * A connection manager has gone unavailable. Close client sessions that were established
 * to the specified connection manager.
 *
 * @param connectionManagerName the connection manager that is no longer available.
 */
public void multiplexerUnavailable(String connectionManagerName) {
    // Remove the connection manager and the hosted sessions
    Map<StreamID, LocalClientSession> sessions = sessionsByManager.remove(connectionManagerName);
    if (sessions != null) {
        for (StreamID streamID : sessions.keySet()) {
            // Remove inverse track of connection manager hosting streamIDs
            streamIDs.remove(streamID);
            // Close the session
            sessions.get(streamID).close();
        }
    }
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:19，
代码来源:ConnectionMultiplexerManager.java

示例15: getNumConnectedClients

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
/**
 * Returns the number of connected clients to a specific connection manager.
 *
 * @param managerName the name of the connection manager.
 * @return the number of connected clients to a specific connection manager.
 */
public int getNumConnectedClients(String managerName) {
    Map<StreamID, LocalClientSession> clients = sessionsByManager.get(managerName);
    if (clients == null) {
        return 0;
    }
    else {
        return clients.size();
    }
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:16，
代码来源:ConnectionMultiplexerManager.java

示例16: removeSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
private void removeSession(Session session) {
    // Remove trace indicating that a connection manager is hosting a connection
    StreamID streamID = session.getStreamID();
    String connectionManagerDomain = streamIDs.remove(streamID);
    // Remove trace indicating that a connection manager is hosting a session
    if (connectionManagerDomain != null) {
        Map<StreamID, LocalClientSession> sessions = sessionsByManager.get(connectionManagerDomain);
        if (sessions != null) {
            sessions.remove(streamID);
        }
    }
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:13，
代码来源:ConnectionMultiplexerManager.java

示例17: LocalSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
/**
 * Creates a session with an underlying connection and permission protection.
 *
 * @param serverName domain of the XMPP server where the new session belongs.
 * @param connection The connection we are proxying.
 * @param streamID unique identifier for this session.
 */
public LocalSession(String serverName, Connection connection, StreamID streamID) {
    conn = connection;
    this.streamID = streamID;
    this.serverName = serverName;
    String id = streamID.getID();
    this.address = new JID(null, serverName, id, true);
    this.sessionManager = SessionManager.getInstance();
}

开发者ID:coodeer，
项目名称:g3server，
代码行数:16，
代码来源:LocalSession.java

示例18: attemptSASLexternal

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
private static LocalOutgoingServerSession attemptSASLexternal(SocketConnection connection, MXParser xpp, XMPPPacketReader reader, String domain, String hostname, String id, StringBuilder openingStream) throws DocumentException, IOException, XmlPullParserException {
	final Logger log = LoggerFactory.getLogger(LocalOutgoingServerSession.class.getName()+"['"+hostname+"']");
    log.debug("Starting EXTERNAL SASL.");
    if (doExternalAuthentication(domain, connection, reader)) {
        log.debug("EXTERNAL SASL was successful.");
        // SASL was successful so initiate a new stream
        connection.deliverRawText(openingStream.toString());

        // Reset the parser
        xpp.resetInput();
        // Skip the opening stream sent by the server
        for (int eventType = xpp.getEventType(); eventType != XmlPullParser.START_TAG;) {
            eventType = xpp.next();
        }

        // SASL authentication was successful so create new OutgoingServerSession
        id = xpp.getAttributeValue("", "id");
        StreamID streamID = new BasicStreamIDFactory().createStreamID(id);
        LocalOutgoingServerSession session = new LocalOutgoingServerSession(domain,
                connection, new OutgoingServerSocketReader(reader), streamID);
        connection.init(session);
        // Set the hostname as the address of the session
        session.setAddress(new JID(null, hostname, null));
        // Set that the session was created using TLS+SASL (no server dialback)
        session.usingServerDialback = false;
        return session;
    }
    else {
        log.debug("EXTERNAL SASL failed.");
        return null;
    }  	
}

开发者ID:coodeer，
项目名称:g3server，
代码行数:33，
代码来源:LocalOutgoingServerSession.java

示例19: createSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
private HttpSession createSession(long rid, InetAddress address, HttpConnection connection) throws UnauthorizedException {
    // Create a ClientSession for this user.
    StreamID streamID = SessionManager.getInstance().nextStreamID();
    // Send to the server that a new client session has been created
    HttpSession session = sessionManager.createClientHttpSession(rid, address, streamID, connection);
    // Register that the new session is associated with the specified stream ID
    sessionMap.put(streamID.getID(), session);
    session.addSessionCloseListener(sessionListener);
    return session;
}

开发者ID:coodeer，
项目名称:g3server，
代码行数:11，
代码来源:HttpSessionManager.java

示例20: HttpSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
public HttpSession(PacketDeliverer backupDeliverer, String serverName, InetAddress address,
                   StreamID streamID, long rid, HttpConnection connection) {
    super(serverName, null, streamID);
    conn = new HttpVirtualConnection(address);
    this.lastActivity = System.currentTimeMillis();
    this.lastRequestID = rid;
    this.backupDeliverer = backupDeliverer;
    this.sslCertificates = connection.getPeerCertificates();
}

开发者ID:coodeer，
项目名称:g3server，
代码行数:10，
代码来源:HttpSession.java

示例21: getStreamID

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
public StreamID getStreamID() {
    // Get it once and cache it since it never changes
    if (streamID == null) {
        ClusterTask task = getRemoteSessionTask(RemoteSessionTask.Operation.getStreamID);
        String id = (String) doSynchronousClusterTask(task);
        streamID = new BasicStreamID(id);
    }
    return streamID;
}

开发者ID:coodeer，
项目名称:g3server，
代码行数:10，
代码来源:RemoteSession.java

示例22: HttpSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
public HttpSession(PacketDeliverer backupDeliverer, String serverName, InetAddress address,
                   StreamID streamID, long rid, HttpConnection connection) {
    super(serverName, null, streamID);
    conn = new HttpVirtualConnection(address);
    this.isClosed = false;
    this.lastActivity = System.currentTimeMillis();
    this.lastRequestID = rid;
    this.backupDeliverer = backupDeliverer;
    this.sslCertificates = connection.getPeerCertificates();
}

开发者ID:idwanglu2010，
项目名称:openfire，
代码行数:11，
代码来源:HttpSession.java

示例23: LocalIncomingServerSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
public LocalIncomingServerSession(String serverName, Connection connection, StreamID streamID, String fromDomain) {
    super(serverName, connection, streamID);
    this.fromDomain = fromDomain;
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:5，
代码来源:LocalIncomingServerSession.java

示例24: LocalComponentSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
public LocalComponentSession(String serverName, Connection conn, StreamID id) {
    super(serverName, conn, id, Locale.getDefault());
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:4，
代码来源:LocalComponentSession.java

示例25: LocalServerSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
public LocalServerSession(String serverName, Connection connection,
        StreamID streamID) {
    super(serverName, connection, streamID, Locale.getDefault());
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:5，
代码来源:LocalServerSession.java

示例26: LocalOutgoingServerSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
public LocalOutgoingServerSession(String localDomain, Connection connection, OutgoingServerSocketReader socketReader, StreamID streamID) {
    super(localDomain, connection, streamID);
    this.socketReader = socketReader;
    socketReader.setSession(this);
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:6，
代码来源:LocalOutgoingServerSession.java

示例27: LocalConnectionMultiplexerSession

import org.jivesoftware.openfire.StreamID; //导入依赖的package包/类
public LocalConnectionMultiplexerSession(String serverName, Connection connection, StreamID streamID) {
    super(serverName, connection, streamID, Locale.getDefault());
}

开发者ID:igniterealtime，
项目名称:Openfire，
代码行数:4，
代码来源:LocalConnectionMultiplexerSession.java