|
|||||||||
| Home >> All >> org >> mom4j >> [ messaging overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: JAVADOC | SOURCE | DOWNLOAD | NESTED | FIELD | CONSTR | METHOD |
DETAIL: FIELD | CONSTR | METHOD | ||||||||
org.mom4j.messaging
Class MessagingServer

java.lang.Objectorg.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)
|
|||||||||
| Home >> All >> org >> mom4j >> [ messaging overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: JAVADOC | SOURCE | DOWNLOAD | NESTED | FIELD | CONSTR | METHOD |
DETAIL: FIELD | CONSTR | METHOD | ||||||||
JAVADOC
org.mom4j.messaging.MessagingServer