submarine.connectors
Class SyncWriter

java.lang.Object
  |
  +--submarine.connectors.SyncWriter
All Implemented Interfaces:
WritingFunction, XMLConfigurable

public class SyncWriter
extends java.lang.Object
implements WritingFunction


Inner Class Summary
private static class SyncWriter.SyncObject
           
 
Field Summary
private  int action
           
private  java.lang.Object lastResult
           
private static int NOTIFY
           
private static java.util.Map syncList
           
private  int timeout
           
private static int UNDEFINED
           
private static int WAIT
           
private  org.w3c.dom.Element xmlKey
           
 
Constructor Summary
SyncWriter()
           
 
Method Summary
 java.lang.Object getResultObject()
           
 void init(org.w3c.dom.Element xml)
           
static void notify(java.lang.String key, Message.MsgContext context, java.lang.Object doc)
           
 boolean putDocument(Message.MsgContext context, java.lang.Object doc)
           
 java.lang.Object putSyncDocument(Message.MsgContext context, java.lang.Object doc)
           
static java.lang.Object waitFor(java.lang.String key, long timeout)
           
 
Methods inherited from class java.lang.Object
, clone, equals, finalize, getClass, hashCode, notify, notifyAll, registerNatives, toString, wait, wait, wait
 

Field Detail

syncList

private static java.util.Map syncList

xmlKey

private org.w3c.dom.Element xmlKey

UNDEFINED

private static final int UNDEFINED

NOTIFY

private static final int NOTIFY

WAIT

private static final int WAIT

action

private int action

timeout

private int timeout

lastResult

private java.lang.Object lastResult
Constructor Detail

SyncWriter

public SyncWriter()
Method Detail

waitFor

public static java.lang.Object waitFor(java.lang.String key,
                                       long timeout)
                                throws java.lang.Exception

notify

public static void notify(java.lang.String key,
                          Message.MsgContext context,
                          java.lang.Object doc)
                   throws java.lang.Exception

putSyncDocument

public java.lang.Object putSyncDocument(Message.MsgContext context,
                                        java.lang.Object doc)
                                 throws java.lang.Exception
Specified by:
putSyncDocument in interface WritingFunction
See Also:
WritingFunction#putSyncDocument(MsgContext, Object)

putDocument

public boolean putDocument(Message.MsgContext context,
                           java.lang.Object doc)
                    throws java.lang.Exception
Specified by:
putDocument in interface WritingFunction
See Also:
WritingFunction#putDocument(MsgContext, Object)

init

public void init(org.w3c.dom.Element xml)
          throws java.lang.Exception
Specified by:
init in interface XMLConfigurable
See Also:
XMLConfigurable#init(Element)

getResultObject

public java.lang.Object getResultObject()

Submarine project. free distribution of this software must include the opensource licence.
Guénolé de Cadoudal.