janus.net
Class LocalConnection

java.lang.Object
  janus.net.Connection
      janus.net.LocalConnection

public class LocalConnection
extends Connection

Diese Klasse stellt die Verbindung der JAVA-Applikation über jToolkit zu den Servern auf einem HP NonStop-System her.

Field Summary

protected com.tandem.tmf.ControlRef

transactionHandle TMF-Transaktions-Handle

Fields inherited from class janus.net.Connection

ACCEPT_SIZE, ADDRESS_SIZE, alias, connected, debug, debugStream, DEFAULT_HOST, DEFAULT_INIT, DEFAULT_PORT, destination, DESTINATION_SIZE, exception, HEADER_SIZE, host, id, init, INIT_SIZE, input, io_buffer, IO_BUFFER_SIZE, io_len, IP_ADDRESS_SIZE, long_number, LONG_NUMBER_SIZE, message_type, MT_ACCEPT, MT_ACK, MT_AWAITIO, MT_CANCEL, MT_DATA, MT_ERROR, MT_INIT, MT_REPLY, MT_TRANSACTION, MT_UNKNOWN, nowait, number, NUMBER_SIZE, nw_buffer, nw_length, nw_offset, option, OPTION_NOWAIT, output, partner, port, reply_len, REPLY_SIZE, server, socket, success_hi, success_lo, TAG_ACCEPT, TAG_ACK, TAG_AWAITIO, TAG_CANCEL, TAG_DATA, TAG_ERROR, TAG_INIT, TAG_REPLY, TAG_SIZE, TAG_TRANSACTION, terminal, TEXT_SIZE, timeout, transaction, TRANSACTION_SIZE, transaction_type, TT_AUTOCOMMIT, TT_BEGIN, TT_COMMIT, TT_IN_PROGRESS, TT_NONE, TT_ROLLBACK, TT_SINGLE, type, ums_address, UMS_ALIAS_SIZE, ums_port, UMS_TERMINAL_SIZE, umsConnection, user_code, user_len, user_offset, userObject

Constructor Summary

LocalConnection(String init, PrintWriter stream)
Konstruktor - Speichert die Parameter

Method Summary

ServerConnection	acceptNew() Umgekehrter Verbindungsaufbau für UMS Nicht implementiert!
int	awaitIo(int timeout) Warte auf I/O.
void	cancel() Breche Nowait-I/O ab.
void	connect() Verbindungsaufbau mit den gespeicherten Parametern.
void	disconnect() Verbindungsabbau
void	finalize() Finalizer: Ruft disconnect() auf.
static void	main(String[] args) Test
protected com.tandem.tmf.Current	resumeTransaction() Nehme die aktuelle Transaktion wieder auf
void	sendBuffer(byte[] buffer, int length) Senden eines beliebigen Puffers.
int	sendMessage(String dest, byte[] msg, int msg_offset, int msg_len, byte[] reply, int reply_offset, int reply_len, int timeout) Message an Server mit Timeout.
void	sendTransaction(int type, int success_lo, int success_hi) Transaktionsmessage.
int	sendUms(String terminal, String alias, byte[] msg, int msg_offset, int msg_len, byte[] reply, int reply_offset, int reply_len) Message an UMS-Client.
protected void	suspendTransaction(com.tandem.tmf.Current current) Parke die aktuelle Transaktion.

Methods inherited from class janus.net.Connection

abortTransaction, acceptUmsServerSocket, autoCommitTransaction, beginTransaction, checkConnection, commitTransaction, connect, connect, createSocket, createUmsServerSocket, endTransaction, getAlias, getBuffer, getConnectionParameter, getDebugStream, getDestination, getException, getInit, getIoLen, getMessageType, getNowaitBuffer, getPartner, getReplyLen, getSuccessHi, getSuccessLo, getTerminal, getTimeout, getTransactionType, getUmsAddress, getUmsConnection, getUmsPort, getUserCode, getUserData, getUserData, getUserLen, getUserObject, getUserOffset, isConnected, isDebug, isNowait, isTransaction, makeUmsDest, notImplemented, println, receiveBuffer, rollbackTransaction, sendAccept, sendBuffer, sendInit, sendMessage, sendMessage, sendMessage, sendMessage, sendMessage, sendMessage, sendMessage, sendMessage, sendMessage, sendUms, sendUms, setDebug, setDebugStream, setDebugStream, setUserObject, singleTransaction, tcpRead, tcpWrite, toString

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

transactionHandle

protected com.tandem.tmf.ControlRef transactionHandle

TMF-Transaktions-Handle

Constructor Detail

LocalConnection

public LocalConnection(String init,
                       PrintWriter stream)
                throws CommException

Konstruktor - Speichert die Parameter

Parameters:

init - Initialisierungs-Information (Pathmon oder RSC.INI-Datei)

stream - Ausgabe-Stream f¨r Debugging

Throws:

CommException - jToolkit nicht verfügbar

Method Detail

acceptNew

public ServerConnection acceptNew()
                           throws CommException

Umgekehrter Verbindungsaufbau für UMS Nicht implementiert!

Overrides:

acceptNew in class Connection

Returns:

Neues Connection-Object

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

awaitIo

public int awaitIo(int timeout)
            throws CommException,
                   TandemException

Warte auf I/O. Nicht implementiert! Die Daten werde im von sendMessage gesetzten Reply-Puffer abgelegt

Overrides:

awaitIo in class Connection

Parameters:

timeout - Timeout (>=0 x0.01s)

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

cancel

public void cancel()
            throws CommException,
                   TandemException

Breche Nowait-I/O ab. Es kann immer nur der letzte I/O abgebrochen werden.

Overrides:

cancel in class Connection

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

connect

public void connect()
             throws CommException,
                    TandemException

Verbindungsaufbau mit den gespeicherten Parametern.

Overrides:

connect in class Connection

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

disconnect

public void disconnect()

Verbindungsabbau

Overrides:

disconnect in class Connection

finalize

public void finalize()

Finalizer: Ruft disconnect() auf.

Overrides:

finalize in class Connection

main

public static void main(String[] args)
                 throws CommException

Test

Throws:

CommException

resumeTransaction

protected com.tandem.tmf.Current resumeTransaction()
                                            throws CommException

Nehme die aktuelle Transaktion wieder auf

Returns:

Current-Objekt

Throws:

CommException

sendBuffer

public void sendBuffer(byte[] buffer,
                       int length)
                throws CommException

Senden eines beliebigen Puffers. Nicht implementiert!

Overrides:

sendBuffer in class Connection

Parameters:

buffer - Daten

length - Länge der Daten

Throws:

CommException - Allgemeiner Kommunikationsfehler

sendMessage

public int sendMessage(String dest,
                       byte[] msg,
                       int msg_offset,
                       int msg_len,
                       byte[] reply,
                       int reply_offset,
                       int reply_len,
                       int timeout)
                throws CommException,
                       TandemException

Message an Server mit Timeout. Beliebige Puffer für Message und Antwort.

Overrides:

sendMessage in class Connection

Parameters:

dest - Name des Servers

msg - Message (Eingabe)

msg_offset - Offset innerhalb von Message

msg_len - Länge der Message

reply - Antwort (Ausgabe)

reply_offset - Offset innerhalb der Antwort

reply_len - Maximale Länge der Antwort

timeout - Timeout (-1 = ohne, 0 = Nowait, >0 = x0.01s)

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

sendTransaction

public void sendTransaction(int type,
                            int success_lo,
                            int success_hi)
                     throws CommException,
                            TandemException

Transaktionsmessage.

Overrides:

sendTransaction in class Connection

Parameters:

type - Transaktionstyp (TT_BEGIN, TT_END, ...)

success_lo - Unterer Vergleichswert für AUTOCOMMIT (16 Bit)

success_hi - Oberer Vergleichswert für AUTOCOMMIT (16 Bit)

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

sendUms

public int sendUms(String terminal,
                   String alias,
                   byte[] msg,
                   int msg_offset,
                   int msg_len,
                   byte[] reply,
                   int reply_offset,
                   int reply_len)
            throws CommException

Message an UMS-Client. Beliebige Puffer für Message und Antwort. Nicht implementiert!

Overrides:

sendUms in class Connection

Parameters:

terminal - UMS-Terminalname

alias - UMS-Aliasname

msg - Message (Eingabe)

msg_offset - Offset innerhalb von Message

msg_len - Länge der Message

reply - Antwort (Ausgabe)

reply_offset - Offset innerhalb der Antwort

reply_len - Maximale Länge der Antwort

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

suspendTransaction

protected void suspendTransaction(com.tandem.tmf.Current current)
                           throws CommException

Parke die aktuelle Transaktion. Setzt transactionHandle und Connection.transaction.

Parameters:

current - Current-Objekt

Throws:

CommException