Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.mom4j.messaging
Class MessagingServer  view MessagingServer download MessagingServer.java

java.lang.Object
  extended byorg.mom4j.messaging.MessagingServer

public final class MessagingServer
extends java.lang.Object


Nested Class Summary
(package private)  class MessagingServer.PeekMessageImpl
           
 
Field Summary
private  org.mom4j.api.Mom4jConfig config
           
private  java.lang.String hostName
           
private  java.util.HashMap locks
           
private  java.lang.Object mutex
           
private  org.mom4j.jndi.NamingServer nserver
           
private  org.mom4j.xcp.XcpServer server
           
private  org.mom4j.mstore.Store store
           
 
Constructor Summary
MessagingServer(org.mom4j.api.Mom4jConfig cfg)
           
 
Method Summary
(package private)  void acknowledge(java.lang.String sessionId, PeekMessage msg)
           
private  void assureTx(java.lang.String sessionId)
           
(package private)  void commit(java.lang.String sessionId)
           
(package private)  void export(java.lang.String name, java.io.Serializable s)
           
 boolean isRunning()
           
private  boolean lock(org.mom4j.mstore.StoreHandle handle)
           
(package private)  PeekMessage peek(java.lang.String sessionId, java.lang.String destination)
           
(package private)  javax.jms.Message receive(java.lang.String sessionId, java.lang.String destination)
           
(package private)  void rollback(java.lang.String sessionId)
           
(package private)  void send(java.lang.String sessionId, java.lang.String[] destinations, javax.jms.Message msg)
           
(package private)  void send(java.lang.String sessionId, java.lang.String destination, javax.jms.Message msg)
           
 Console start(boolean verbose)
           
(package private)  void stop()
           
private  void unlock(org.mom4j.mstore.StoreHandle handle)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

config

private org.mom4j.api.Mom4jConfig config

server

private org.mom4j.xcp.XcpServer server

store

private org.mom4j.mstore.Store store

locks

private java.util.HashMap locks

mutex

private java.lang.Object mutex

nserver

private org.mom4j.jndi.NamingServer nserver

hostName

private java.lang.String hostName
Constructor Detail

MessagingServer

public MessagingServer(org.mom4j.api.Mom4jConfig cfg)
Method Detail

start

public Console start(boolean verbose)

isRunning

public boolean isRunning()

stop

void stop()

export

void export(java.lang.String name,
            java.io.Serializable s)

send

void send(java.lang.String sessionId,
          java.lang.String destination,
          javax.jms.Message msg)
    throws java.io.IOException,
           javax.jms.JMSException

send

void send(java.lang.String sessionId,
          java.lang.String[] destinations,
          javax.jms.Message msg)
    throws java.io.IOException,
           javax.jms.JMSException

peek

PeekMessage peek(java.lang.String sessionId,
                 java.lang.String destination)
           throws java.io.IOException,
                  javax.jms.JMSException

acknowledge

void acknowledge(java.lang.String sessionId,
                 PeekMessage msg)
           throws java.io.IOException

receive

javax.jms.Message receive(java.lang.String sessionId,
                          java.lang.String destination)
                    throws java.io.IOException,
                           javax.jms.JMSException

lock

private boolean lock(org.mom4j.mstore.StoreHandle handle)

unlock

private void unlock(org.mom4j.mstore.StoreHandle handle)

commit

void commit(java.lang.String sessionId)

rollback

void rollback(java.lang.String sessionId)

assureTx

private void assureTx(java.lang.String sessionId)