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 org.apache.activemq.command.SessionId

        });
        // asyncConnectionThread.allowCoreThreadTimeOut(true);


        this.info = new ConnectionInfo(new ConnectionId(CONNECTION_ID_GENERATOR.generateId()));
        this.info.setManageable(true);
        this.connectionSessionId = new SessionId(info.getConnectionId(), -1);


        this.transport.setTransportListener(this);


        this.stats = new JMSConnectionStatsImpl(sessions, this instanceof XAConnection);
        this.factoryStats.addConnection(this);

View Full Code Here

Examples of org.apache.activemq.command.SessionId


    /**
     * @return sessionId
     */
    protected SessionId getNextSessionId() {
        return new SessionId(info.getConnectionId(), sessionIdGenerator.getNextSequenceId());
    }

View Full Code Here

Examples of org.apache.activemq.command.SessionId

     */
    public ConnectionConsumer createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector, ServerSessionPool sessionPool, int maxMessages,
                                                              boolean noLocal) throws JMSException {
        checkClosedOrFailed();
        ensureConnectionInfoSent();
        SessionId sessionId = new SessionId(info.getConnectionId(), -1);
        ConsumerInfo info = new ConsumerInfo(new ConsumerId(sessionId, consumerIdGenerator.getNextSequenceId()));
        info.setDestination(ActiveMQMessageTransformation.transformDestination(topic));
        info.setSubscriptionName(subscriptionName);
        info.setSelector(messageSelector);
        info.setPrefetchSize(maxMessages);

View Full Code Here

Examples of org.apache.activemq.command.SessionId

            this.isConnectionInfoSentToBroker = true;
            // Add a temp destination advisory consumer so that
            // We know what the valid temporary destinations are on the
            // broker without having to do an RPC to the broker.
    
            ConsumerId consumerId = new ConsumerId(new SessionId(info.getConnectionId(), -1), consumerIdGenerator.getNextSequenceId());
            if (watchTopicAdvisories) {
                advisoryConsumer = new AdvisoryConsumer(this, consumerId);
            }
        }
    }

View Full Code Here

Examples of org.apache.activemq.command.SessionId

    protected ConnectionId createConnectionId(String string) {
        return new ConnectionId(string);
    }


    protected SessionId createSessionId(String string) {
        return new SessionId(createConnectionId(string), ++counter);
    }

View Full Code Here

Examples of org.apache.activemq.command.SessionId

        return TRACKED_RESPONSE_MARKER;
    }


    public Response processAddProducer(ProducerInfo info) {
        if (info != null && info.getProducerId() != null) {
            SessionId sessionId = info.getProducerId().getParentId();
            if (sessionId != null) {
                ConnectionId connectionId = sessionId.getParentId();
                if (connectionId != null) {
                    ConnectionState cs = connectionStates.get(connectionId);
                    if (cs != null) {
                        SessionState ss = cs.getSessionState(sessionId);
                        if (ss != null) {

View Full Code Here

Examples of org.apache.helix.api.id.SessionId

     * map of participant-id to map of resource-id to current-state
     */
    Map<String, Map<String, CurrentState>> currentStateMap = Maps.newHashMap();
    for (String participantName : liveInstanceMap.keySet()) {
      LiveInstance liveInstance = liveInstanceMap.get(participantName);
      SessionId sessionId = liveInstance.getTypedSessionId();
      Map<String, CurrentState> instanceCurStateMap;
      if (useCache) {
        instanceCurStateMap = _cache.getCurrentState(participantName, sessionId.stringify());
      } else {
        instanceCurStateMap =
            _accessor.getChildValuesMap(_keyBuilder.currentStates(participantName,
                sessionId.stringify()));
      }
      currentStateMap.put(participantName, instanceCurStateMap);
    }


    // read all the participants

View Full Code Here

Examples of org.jboss.ejb.client.SessionID

        context.putPrivateData(Component.class, ejbComponent);
        context.putPrivateData(ComponentView.class, view);




        if (locator instanceof StatefulEJBLocator) {
            final SessionID sessionID = ((StatefulEJBLocator) locator).getSessionId();
            context.putPrivateData(SessionID.class, sessionID);
        } else if (locator instanceof EntityEJBLocator) {
            final Object primaryKey = ((EntityEJBLocator) locator).getPrimaryKey();
            context.putPrivateData(EntityBeanComponent.PRIMARY_KEY_CONTEXT_KEY, primaryKey);
        }

View Full Code Here

Examples of org.jboss.ejb.client.SessionID

        final EJBComponent component = ejbInfo.getEjbComponent();
        if (!(component instanceof StatefulSessionComponent)) {
            throw MESSAGES.notStatefulSessionBean(beanName, appName, moduleName, distinctName);
        }
        final StatefulSessionComponent statefulComponent = (StatefulSessionComponent) component;
        final SessionID sessionID = statefulComponent.createSession();
        return new StatefulEJBLocator<T>(viewType, appName, moduleName, beanName, distinctName, sessionID, statefulComponent.getCache().getStrictAffinity(), this.getNodeName());
    }

View Full Code Here

Examples of org.jboss.ejb.client.SessionID

        // invoke the method and write out the response on a separate thread
        executorService.submit(runnable);
    }


    private Affinity getWeakAffinity(final StatefulSessionComponent statefulSessionComponent, final StatefulEJBLocator<?> statefulEJBLocator) {
        final SessionID sessionID = statefulEJBLocator.getSessionId();
        return statefulSessionComponent.getCache().getWeakAffinity(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.