janus.net
Class Connection

java.lang.Object
  janus.net.Connection

Direct Known Subclasses:

LocalConnection, SecureConnection, ServerConnection

public class Connection
extends Object

Diese Klasse stellt die Verbindung der JAVA-Applikation über ein Gateway oder den TCP_TAN-Server zu den Servern auf einem Tandem-System her.

Das Gateway (TCP_RSC) muss auf einer Plattform installiert werden, die RSC unterstützt:

     JVM <--(TCP/IP)--> TCP_RSC <--(RSC)--> TDP <--(PATHSEND)--> Server
  

Alternativ kann direkt der Prozess TCP_TAN auf dem Tandem-System installiert und angesprochen werden. Die Lösung kommt so ohne RSC-Lizenzen oder externe Gateway-Rechner aus:

     JVM <--(TCP/IP)--> TCP_TAN <--(PATHSEND)--> Server
  

Field Summary

protected static int	ACCEPT_SIZE Protokollkonstante
protected static int	ADDRESS_SIZE Protokollkonstante
protected String	alias UMS-Aliasname (Server)
protected boolean	connected true, wenn Verbindung besteht
protected boolean	debug Debug einschalten.
protected PrintWriter	debugStream PrintWriter für Debugging
static String	DEFAULT_HOST Standard TCP/IP-Name des Gatewayhosts
static String	DEFAULT_INIT Standardtext für INIT-Nachricht ("$PM")
static int	DEFAULT_PORT Standard TCP/IP-Portnummer des Gateways
protected String	destination Zielfeld aus DATA-Nachricht
protected static int	DESTINATION_SIZE Protokollkonstante
protected CommException	exception Letzter Fehler
protected static int	HEADER_SIZE Protokollkonstante
protected String	host TCP/IP-Adresse des Gateway-Systems oder Hosts
protected int	id ID für das Debugging
protected String	init Initialisierungs-Information (Pathmon-Name oder RSC.INI-Datei)
protected static int	INIT_SIZE Protokollkonstante
protected InputStream	input TCP/IP-Eingabe-Strom
protected byte[]	io_buffer Sende und Empfangspuffer
protected static int	IO_BUFFER_SIZE Protokollkonstante
protected int	io_len Gesamt-Pufferlänge
protected static int	IP_ADDRESS_SIZE Protokollkonstante
protected NumberString	long_number Hilfsfeld für große Zahlen
protected static int	LONG_NUMBER_SIZE Protokollkonstante
protected int	message_type Art der empfangenen Nachricht
static int	MT_ACCEPT Nachrichtentyp Verbindungsannahme
static int	MT_ACK Nachrichtentyp positive Quittung
static int	MT_AWAITIO Nachrichtentyp Warten auf I/O-Completion
static int	MT_CANCEL Nachrichtentyp I/O-Abbruch
static int	MT_DATA Nachrichtentyp Server-Message
static int	MT_ERROR Nachrichtentyp negative Quittung
static int	MT_INIT Nachrichtentyp Initialisierung
static int	MT_REPLY Nachrichtentyp Server-Antwort
static int	MT_TRANSACTION Nachrichtentyp Transaktion
protected static int	MT_UNKNOWN Nachrichtentyp unbekannt
protected boolean	nowait true, wenn ein Nowait-I/O aussteht
protected NumberString	number Hilfsfeld für Zahlen
protected static int	NUMBER_SIZE Protokollkonstante
protected byte[]	nw_buffer Verweis auf Puffer für Reply aus Nowait-I/O
protected int	nw_length Maximale Länge des Nowait-Reply
protected int	nw_offset Offset innerhalb des Nowait-Reply
protected int	option Options-Bits
protected static int	OPTION_NOWAIT Bedeutung der Optionen
protected OutputStream	output TCP/IP-Ausgabe-Strom
protected String	partner Prozessname des Gegenprozesses (TCP_TAN) fuer UMS Bei Servern die letzte adressierte Destination
protected int	port TCP/IP-Port des Gateway-Systems oder Hosts
protected int	reply_len Maximale Antwortlänge
protected static int	REPLY_SIZE Protokollkonstante
protected boolean	server true, wenn dies eine Serververbindung ist
protected Socket	socket TCP/IP-Socket zum Gateway
protected int	success_hi Oberer Grenzwert für erfolgreiche Transaktion
protected int	success_lo Unterer Grenzwert für erfolgreiche Transaktion
protected static String	TAG_ACCEPT Nachrichtentag Verbindungsannahme
protected static String	TAG_ACK Nachrichtentag positive Quittung
protected static String	TAG_AWAITIO Nachrichtentag Warten auf I/O-Completion
protected static String	TAG_CANCEL Nachrichtentag I/O-Abbruch
protected static String	TAG_DATA Nachrichtentag Server-Message
protected static String	TAG_ERROR Nachrichtentag negative Quittung
protected static String	TAG_INIT Nachrichtentag Initialisierung
protected static String	TAG_REPLY Nachrichtentag Server-Antwort
protected static int	TAG_SIZE Protokollkonstante
protected static String	TAG_TRANSACTION Nachrichtentag Transaktion
protected String	terminal UMS-Terminalname (Server)
protected static int	TEXT_SIZE Protokollkonstante
protected int	timeout Timeout-Wert (aus DATA-Nachricht oder AWAITIO)
protected boolean	transaction true, wenn Transaktion aktiv
protected static int	TRANSACTION_SIZE Protokollkonstante
protected int	transaction_type Transaktionstyp
static int	TT_AUTOCOMMIT Transaktionstyp - Automatische Transaktion
static int	TT_BEGIN Transaktionstyp - BeginTransaction
static int	TT_COMMIT Transaktionstyp - EndTransaction
static int	TT_IN_PROGRESS Transaktionstyp - Transaktion aktiv (nur intern benutzt)
static int	TT_NONE Transaktionstyp - Keine Transaktion
static int	TT_ROLLBACK Transaktionstyp - AbortTransaktion
static int	TT_SINGLE Transaktionstyp - Einzeltransaktion
protected char	type Typ für das Debugging
protected String	ums_address IP-Adresse (UMS)
protected static int	UMS_ALIAS_SIZE Protokollkonstante
protected int	ums_port IP-Port (UMS)
protected static int	UMS_TERMINAL_SIZE Protokollkonstante
protected ServerConnection	umsConnection UMS-Connection
protected int	user_code Fehlernummer aus Nachricht
protected int	user_len Länge der Nutzdaten
protected int	user_offset Beginn der Nutzdaten
protected Object	userObject User-Object (@see #setUserObject)

Constructor Summary

protected	Connection() Konstruktor ohne Parameter - für abgeleitete Klassen
	Connection(ConnectionParameter param) Konstruktor - baut die Verbindung zum Tandem-System auf.
	Connection(ConnectionParameter param, boolean debug) Konstruktor - baut die Verbindung zum Tandem-System auf.
	Connection(String host, int port, String init) Konstruktor - baut die Verbindung zum Tandem-System auf.
	Connection(String host, int port, String init, boolean compress, boolean debug) Konstruktor - baut die Verbindung zum Tandem-System auf.
	Connection(String host, int port, String init, boolean compress, PrintWriter stream) Konstruktor - baut die Verbindung zum Tandem-System auf.
	Connection(String host, int port, String init, boolean compress, String file) Konstruktor - baut die Verbindung zum Tandem-System auf.

Method Summary

void	abortTransaction() Zurücknehmen einer Transaktion (Alias für rollbackTransaction.)
ServerConnection	acceptNew() Umgekehrter Verbindungsaufbau für UMS
protected Socket	acceptUmsServerSocket(ServerSocket ss) Nehme den UMS-Server-Socket an.
void	autoCommitTransaction(int success_lo, int success_hi) Automatisches Transaktionsende.
int	awaitIo(int timeout) Warte auf I/O.
void	beginTransaction() Beginn einer Transaktion.
void	cancel() Breche Nowait-I/O ab.
protected void	checkConnection() Test auf bestehende Verbindung.
void	commitTransaction() Beenden einer Transaktion (Alias für endTransaction.)
void	connect() Verbindungsaufbau mit den gespeicherten Parametern.
void	connect(String host, int port, String init) Verbindungsaufbau.
void	connect(String host, int port, String init, boolean compress) Verbindungsaufbau.
protected void	createSocket() Erzeuge den Client-Socket.
protected ServerSocket	createUmsServerSocket(int port) Erzeuge den UMS-Server-Socket.
void	disconnect() Verbindungsabbau
void	endTransaction() Beenden einer Transaktion.
void	finalize() Finalizer: Ruft disconnect() auf.
String	getAlias() Rückgabe des UMS-Alias
byte[]	getBuffer() Rückgabe des Byte-Puffers
ConnectionParameter	getConnectionParameter() Rückgabe der Verbindungsparameter
PrintWriter	getDebugStream() Rückgabe des DebugStream
String	getDestination() Rückgabe der Destination der letzten DATA-Nachricht
CommException	getException() Rückgabe des letzten Fehlers
String	getInit() Rückgabe der Init-Nachricht bzw. der Antwort darauf
int	getIoLen() Rückgabe des Byte-Puffers
int	getMessageType() Rückgabe des Nachrichtentyps
byte[]	getNowaitBuffer() Rückgabe des Nowait-Puffers
String	getPartner() Rückgabe des Gegenprozesses (TCP_TAN) bzw. der Destination der letzten DATA-Nachricht
int	getReplyLen() Rückgabe der erwarteten Antwortlänge
int	getSuccessHi() Rückgabe des oberen Autocommitwertes
int	getSuccessLo() Rückgabe des unteren Autocommitwertes
String	getTerminal() Rückgabe des UMS-Terminalnamens
int	getTimeout() Rückgabe des Timeouts
int	getTransactionType() Rückgabe des Transaktionstyps
String	getUmsAddress() Rückgabe der IP-Adresse für die UMS-Connection
ServerConnection	getUmsConnection() Rückgabe der UMS-Connection
int	getUmsPort() Rückgabe des IP-Ports für die UMS-Connection
int	getUserCode() Rückgabe des Fehlercodes
String	getUserData() Rückgabe der User-Daten als String.
int	getUserData(byte[] dst, int offset, int maxlen) Rückgabe der User-Daten.
int	getUserLen() Rückgabe der Länge der User-Daten
Object	getUserObject() Zugriff auf das User-Objekt
int	getUserOffset() Rückgabe des Offsets der User-Daten
boolean	isConnected() Rückgabe des Verbindungsstatus
boolean	isDebug() Rückgabe des Debug-Status
boolean	isNowait() Rückgabe des Nowait-Status
boolean	isTransaction() Rückgabe des Transaktionsstatus
static void	main(String[] args) Test
protected String	makeUmsDest(String terminal, String alias, int reply_len) Konstruiere die spezielle UMS-Destination
void	notImplemented(String caller) Wirf CommException NOT_IMPLEMENTED
void	println(Object text) Debugging
void	receiveBuffer() Empfangen der Antwort in io_buffer.
void	rollbackTransaction() Zurücknehmen einer Transaktion.
protected void	sendAccept(int port) Accept-Nachricht.
void	sendBuffer(byte[] buffer, int length) Senden eines beliebigen Puffers.
protected void	sendBuffer(String tag, int len, int opt) Senden einer Nachricht.
protected void	sendInit(String init) Init-Nachricht.
protected int	sendMessage(String dest) Message an Server.
int	sendMessage(String dest, byte[] msg, int msg_offset, int msg_len, byte[] reply, int reply_offset, int reply_len) Message an Server.
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.
protected int	sendMessage(String dest, int timeout) Message an Server mit Timeout.
int	sendMessage(String dest, MessageElement[] msg, MessageElement[] reply) Message an Server.
int	sendMessage(String dest, MessageElement[] msg, MessageElement[] reply, int timeout) Message an Server mit Timeout.
int	sendMessage(String dest, MessageElement msg, int msg_len, MessageElement reply) Message an Server.
int	sendMessage(String dest, MessageElement msg, int msg_len, MessageElement reply, int timeout) Message an Server mit Timeout.
int	sendMessage(String dest, MessageElement msg, MessageElement reply) Message an Server.
int	sendMessage(String dest, MessageElement msg, MessageElement reply, 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.
int	sendUms(String terminal, String alias, MessageElement msg, int msg_len, MessageElement reply) Message an UMS-Client.
int	sendUms(String terminal, String alias, MessageElement msg, MessageElement reply) Message an UMS-Client.
boolean	setDebug(boolean debug) Setzen des Debug-Status
void	setDebugStream(PrintWriter stream) Setzen des debugStream und Debug-Status
void	setDebugStream(String file) Setzen des debugStream und Debug-Status
void	setUserObject(Object obj) Speichern eines User-Objektes Solche Objekte können zum Beispiel Puffer enthalten die pro Verbindung (in einem Pool) nur einmal erzeugt werden sollen Beispiel: conn = pool.getConnection( timeout ); MyMessage msg = (MyMessage) conn.getUserObject(); if ( msg == null ) { msg = new MyMessage(); conn.setUserObject( msg ); }
void	singleTransaction(int success_lo, int success_hi) Automatische Einzeltransaktion.
protected void	tcpRead(int offset, int len) Empfangen einer definierten Anzahl von Bytes über die Socket-Verbindung.
protected void	tcpWrite() Senden des Puffers über die Socket-Verbindung.
String	toString() Stringdarstellung

Methods inherited from class java.lang.Object

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

Field Detail

ACCEPT_SIZE

protected static final int ACCEPT_SIZE

Protokollkonstante

See Also:

Constant Field Values

ADDRESS_SIZE

protected static final int ADDRESS_SIZE

Protokollkonstante

See Also:

Constant Field Values

alias

protected String alias

UMS-Aliasname (Server)

connected

protected boolean connected

true, wenn Verbindung besteht

debug

protected boolean debug

Debug einschalten.

debugStream

protected PrintWriter debugStream

PrintWriter für Debugging

DEFAULT_HOST

public static final String DEFAULT_HOST

Standard TCP/IP-Name des Gatewayhosts

See Also:

Constant Field Values

DEFAULT_INIT

public static final String DEFAULT_INIT

Standardtext für INIT-Nachricht ("$PM")

See Also:

Constant Field Values

DEFAULT_PORT

public static final int DEFAULT_PORT

Standard TCP/IP-Portnummer des Gateways

See Also:

Constant Field Values

destination

protected String destination

Zielfeld aus DATA-Nachricht

DESTINATION_SIZE

protected static final int DESTINATION_SIZE

Protokollkonstante

See Also:

Constant Field Values

exception

protected CommException exception

Letzter Fehler

HEADER_SIZE

protected static final int HEADER_SIZE

Protokollkonstante

See Also:

Constant Field Values

host

protected String host

TCP/IP-Adresse des Gateway-Systems oder Hosts

id

protected int id

ID für das Debugging

init

protected String init

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

INIT_SIZE

protected static final int INIT_SIZE

Protokollkonstante

See Also:

Constant Field Values

input

protected InputStream input

TCP/IP-Eingabe-Strom

io_buffer

protected byte[] io_buffer

Sende und Empfangspuffer

IO_BUFFER_SIZE

protected static final int IO_BUFFER_SIZE

Protokollkonstante

See Also:

Constant Field Values

io_len

protected int io_len

Gesamt-Pufferlänge

IP_ADDRESS_SIZE

protected static final int IP_ADDRESS_SIZE

Protokollkonstante

See Also:

Constant Field Values

long_number

protected NumberString long_number

Hilfsfeld für große Zahlen

LONG_NUMBER_SIZE

protected static final int LONG_NUMBER_SIZE

Protokollkonstante

See Also:

Constant Field Values

message_type

protected int message_type

Art der empfangenen Nachricht

MT_ACCEPT

public static final int MT_ACCEPT

Nachrichtentyp Verbindungsannahme

See Also:

Constant Field Values

MT_ACK

public static final int MT_ACK

Nachrichtentyp positive Quittung

See Also:

Constant Field Values

MT_AWAITIO

public static final int MT_AWAITIO

Nachrichtentyp Warten auf I/O-Completion

See Also:

Constant Field Values

MT_CANCEL

public static final int MT_CANCEL

Nachrichtentyp I/O-Abbruch

See Also:

Constant Field Values

MT_DATA

public static final int MT_DATA

Nachrichtentyp Server-Message

See Also:

Constant Field Values

MT_ERROR

public static final int MT_ERROR

Nachrichtentyp negative Quittung

See Also:

Constant Field Values

MT_INIT

public static final int MT_INIT

Nachrichtentyp Initialisierung

See Also:

Constant Field Values

MT_REPLY

public static final int MT_REPLY

Nachrichtentyp Server-Antwort

See Also:

Constant Field Values

MT_TRANSACTION

public static final int MT_TRANSACTION

Nachrichtentyp Transaktion

See Also:

Constant Field Values

MT_UNKNOWN

protected static final int MT_UNKNOWN

Nachrichtentyp unbekannt

See Also:

Constant Field Values

nowait

protected boolean nowait

true, wenn ein Nowait-I/O aussteht

number

protected NumberString number

Hilfsfeld für Zahlen

NUMBER_SIZE

protected static final int NUMBER_SIZE

Protokollkonstante

See Also:

Constant Field Values

nw_buffer

protected byte[] nw_buffer

Verweis auf Puffer für Reply aus Nowait-I/O

nw_length

protected int nw_length

Maximale Länge des Nowait-Reply

nw_offset

protected int nw_offset

Offset innerhalb des Nowait-Reply

option

protected int option

Options-Bits

OPTION_NOWAIT

protected static final int OPTION_NOWAIT

Bedeutung der Optionen

See Also:

Constant Field Values

output

protected OutputStream output

TCP/IP-Ausgabe-Strom

partner

protected String partner

Prozessname des Gegenprozesses (TCP_TAN) fuer UMS Bei Servern die letzte adressierte Destination

port

protected int port

TCP/IP-Port des Gateway-Systems oder Hosts

reply_len

protected int reply_len

Maximale Antwortlänge

REPLY_SIZE

protected static final int REPLY_SIZE

Protokollkonstante

See Also:

Constant Field Values

server

protected boolean server

true, wenn dies eine Serververbindung ist

socket

protected Socket socket

TCP/IP-Socket zum Gateway

success_hi

protected int success_hi

Oberer Grenzwert für erfolgreiche Transaktion

success_lo

protected int success_lo

Unterer Grenzwert für erfolgreiche Transaktion

TAG_ACCEPT

protected static final String TAG_ACCEPT

Nachrichtentag Verbindungsannahme

See Also:

Constant Field Values

TAG_ACK

protected static final String TAG_ACK

Nachrichtentag positive Quittung

See Also:

Constant Field Values

TAG_AWAITIO

protected static final String TAG_AWAITIO

Nachrichtentag Warten auf I/O-Completion

See Also:

Constant Field Values

TAG_CANCEL

protected static final String TAG_CANCEL

Nachrichtentag I/O-Abbruch

See Also:

Constant Field Values

TAG_DATA

protected static final String TAG_DATA

Nachrichtentag Server-Message

See Also:

Constant Field Values

TAG_ERROR

protected static final String TAG_ERROR

Nachrichtentag negative Quittung

See Also:

Constant Field Values

TAG_INIT

protected static final String TAG_INIT

Nachrichtentag Initialisierung

See Also:

Constant Field Values

TAG_REPLY

protected static final String TAG_REPLY

Nachrichtentag Server-Antwort

See Also:

Constant Field Values

TAG_SIZE

protected static final int TAG_SIZE

Protokollkonstante

See Also:

Constant Field Values

TAG_TRANSACTION

protected static final String TAG_TRANSACTION

Nachrichtentag Transaktion

See Also:

Constant Field Values

terminal

protected String terminal

UMS-Terminalname (Server)

TEXT_SIZE

protected static final int TEXT_SIZE

Protokollkonstante

See Also:

Constant Field Values

timeout

protected int timeout

Timeout-Wert (aus DATA-Nachricht oder AWAITIO)

transaction

protected boolean transaction

true, wenn Transaktion aktiv

TRANSACTION_SIZE

protected static final int TRANSACTION_SIZE

Protokollkonstante

See Also:

Constant Field Values

transaction_type

protected int transaction_type

Transaktionstyp

TT_AUTOCOMMIT

public static final int TT_AUTOCOMMIT

Transaktionstyp - Automatische Transaktion

See Also:

Constant Field Values

TT_BEGIN

public static final int TT_BEGIN

Transaktionstyp - BeginTransaction

See Also:

Constant Field Values

TT_COMMIT

public static final int TT_COMMIT

Transaktionstyp - EndTransaction

See Also:

Constant Field Values

TT_IN_PROGRESS

public static final int TT_IN_PROGRESS

Transaktionstyp - Transaktion aktiv (nur intern benutzt)

See Also:

Constant Field Values

TT_NONE

public static final int TT_NONE

Transaktionstyp - Keine Transaktion

See Also:

Constant Field Values

TT_ROLLBACK

public static final int TT_ROLLBACK

Transaktionstyp - AbortTransaktion

See Also:

Constant Field Values

TT_SINGLE

public static final int TT_SINGLE

Transaktionstyp - Einzeltransaktion

See Also:

Constant Field Values

type

protected char type

Typ für das Debugging

ums_address

protected String ums_address

IP-Adresse (UMS)

UMS_ALIAS_SIZE

protected static final int UMS_ALIAS_SIZE

Protokollkonstante

See Also:

Constant Field Values

ums_port

protected int ums_port

IP-Port (UMS)

UMS_TERMINAL_SIZE

protected static final int UMS_TERMINAL_SIZE

Protokollkonstante

See Also:

Constant Field Values

umsConnection

protected ServerConnection umsConnection

UMS-Connection

user_code

protected int user_code

Fehlernummer aus Nachricht

user_len

protected int user_len

Länge der Nutzdaten

user_offset

protected int user_offset

Beginn der Nutzdaten

userObject

protected Object userObject

User-Object (@see #setUserObject)

Constructor Detail

Connection

protected Connection()

Konstruktor ohne Parameter - für abgeleitete Klassen

Connection

public Connection(ConnectionParameter param)
           throws CommException,
                  TandemException

Konstruktor - baut die Verbindung zum Tandem-System auf.

Parameters:

param - Parameter zum Aufbau der Verbindung

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

Connection

public Connection(ConnectionParameter param,
                  boolean debug)
           throws CommException,
                  TandemException

Konstruktor - baut die Verbindung zum Tandem-System auf. Unterstüzt das debugging

Parameters:

param - Parameter zum Aufbau der Verbindung

debug - Testinformationen auf debugStream ausgeben

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

Connection

public Connection(String host,
                  int port,
                  String init)
           throws CommException,
                  TandemException

Konstruktor - baut die Verbindung zum Tandem-System auf. Schaltet Testausgaben aus.

Parameters:

host - TCP/IP-Adresse des Gateway-Systems

port - TCP/IP-Port des Gateway-Systems

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

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

Connection

public Connection(String host,
                  int port,
                  String init,
                  boolean compress,
                  boolean debug)
           throws CommException,
                  TandemException

Konstruktor - baut die Verbindung zum Tandem-System auf.

Parameters:

host - TCP/IP-Adresse des Gateway-Systems oder Hosts

port - TCP/IP-Port des Gateway-Systems oder Hosts

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

compress - Kompression einschalten (ohne Funktion)

debug - Testinformationen auf debugStream ausgeben

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

Connection

public Connection(String host,
                  int port,
                  String init,
                  boolean compress,
                  PrintWriter stream)
           throws CommException,
                  TandemException

Konstruktor - baut die Verbindung zum Tandem-System auf.

Parameters:

host - TCP/IP-Adresse des Gateway-Systems oder Hosts

port - TCP/IP-Port des Gateway-Systems oder Hosts

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

compress - Kompression einschalten (ohne Funktion)

stream - Ausgabe-Stream f¨r Debugging

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

Connection

public Connection(String host,
                  int port,
                  String init,
                  boolean compress,
                  String file)
           throws CommException,
                  TandemException

Konstruktor - baut die Verbindung zum Tandem-System auf.

Parameters:

host - TCP/IP-Adresse des Gateway-Systems oder Hosts

port - TCP/IP-Port des Gateway-Systems oder Hosts

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

compress - Kompression einschalten (ohne Funktion)

file - Name der Debug-Datei

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

Method Detail

abortTransaction

public void abortTransaction()
                      throws CommException,
                             TandemException

Zurücknehmen einer Transaktion (Alias für rollbackTransaction.)

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

acceptNew

public ServerConnection acceptNew()
                           throws CommException

Umgekehrter Verbindungsaufbau für UMS

Returns:

Neues Connection-Object

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

acceptUmsServerSocket

protected Socket acceptUmsServerSocket(ServerSocket ss)
                                throws IOException

Nehme den UMS-Server-Socket an. Kann von abgeleiteten Klassen überschrieben werden.

Parameters:

ss - Server-Socket

Returns:

der verbundene Socket

Throws:

IOException

autoCommitTransaction

public void autoCommitTransaction(int success_lo,
                                  int success_hi)
                           throws CommException,
                                  TandemException

Automatisches Transaktionsende. Die Parameter success_lo und success_hi bilden die Grenzen, zwischen denen die ersten 16 Bit der Server-Antwort beim nächsten Aufruf von sendMessage() liegen müssen, damit die Transaktion automatisch beendet wird. Die Statusfunktion isTransaction() ist true, wenn die Transaktion nicht automatisch beendet werden konnte.

Parameters:

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

See Also:

sendMessage(java.lang.String, janus.util.MessageElement, janus.util.MessageElement), singleTransaction(int, int), isTransaction()

awaitIo

public int awaitIo(int timeout)
            throws CommException,
                   TandemException

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

Parameters:

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

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

beginTransaction

public void beginTransaction()
                      throws CommException,
                             TandemException

Beginn einer Transaktion.

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.

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

checkConnection

protected void checkConnection()
                        throws CommException

Test auf bestehende Verbindung.

Throws:

CommException - wenn keine Verbindung besteht.

commitTransaction

public void commitTransaction()
                       throws CommException,
                              TandemException

Beenden einer Transaktion (Alias für endTransaction.)

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

connect

public void connect()
             throws CommException,
                    TandemException

Verbindungsaufbau mit den gespeicherten Parametern.

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

connect

public void connect(String host,
                    int port,
                    String init)
             throws CommException,
                    TandemException

Verbindungsaufbau.

Parameters:

host - TCP/IP-Adresse des Gateway-Systems oder Hosts

port - TCP/IP-Port des Gateway-Systems oder Hosts

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

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

connect

public void connect(String host,
                    int port,
                    String init,
                    boolean compress)
             throws CommException,
                    TandemException

Verbindungsaufbau.

Parameters:

host - TCP/IP-Adresse des Gateway-Systems oder Hosts

port - TCP/IP-Port des Gateway-Systems oder Hosts

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

compress - Einschalten der Kompression (ohne Funktion)

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

createSocket

protected void createSocket()
                     throws IOException

Erzeuge den Client-Socket. Kann von abgeleiteten Klassen überschrieben werden.

Throws:

IOException

createUmsServerSocket

protected ServerSocket createUmsServerSocket(int port)
                                      throws IOException

Erzeuge den UMS-Server-Socket. Kann von abgeleiteten Klassen überschrieben werden.

Parameters:

port - Portnummer

Returns:

new ServerSocket(port)

Throws:

IOException

disconnect

public void disconnect()

Verbindungsabbau

endTransaction

public void endTransaction()
                    throws CommException,
                           TandemException

Beenden einer Transaktion.

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

finalize

public void finalize()

Finalizer: Ruft disconnect() auf.

Overrides:

finalize in class Object

getAlias

public String getAlias()

Rückgabe des UMS-Alias

getBuffer

public byte[] getBuffer()

Rückgabe des Byte-Puffers

getConnectionParameter

public ConnectionParameter getConnectionParameter()

Rückgabe der Verbindungsparameter

getDebugStream

public PrintWriter getDebugStream()

Rückgabe des DebugStream

getDestination

public String getDestination()

Rückgabe der Destination der letzten DATA-Nachricht

getException

public CommException getException()

Rückgabe des letzten Fehlers

getInit

public String getInit()

Rückgabe der Init-Nachricht bzw. der Antwort darauf

getIoLen

public int getIoLen()

Rückgabe des Byte-Puffers

getMessageType

public int getMessageType()

Rückgabe des Nachrichtentyps

getNowaitBuffer

public byte[] getNowaitBuffer()

Rückgabe des Nowait-Puffers

getPartner

public String getPartner()

Rückgabe des Gegenprozesses (TCP_TAN) bzw. der Destination der letzten DATA-Nachricht

getReplyLen

public int getReplyLen()

Rückgabe der erwarteten Antwortlänge

getSuccessHi

public int getSuccessHi()

Rückgabe des oberen Autocommitwertes

getSuccessLo

public int getSuccessLo()

Rückgabe des unteren Autocommitwertes

getTerminal

public String getTerminal()

Rückgabe des UMS-Terminalnamens

getTimeout

public int getTimeout()

Rückgabe des Timeouts

getTransactionType

public int getTransactionType()

Rückgabe des Transaktionstyps

getUmsAddress

public String getUmsAddress()

Rückgabe der IP-Adresse für die UMS-Connection

getUmsConnection

public ServerConnection getUmsConnection()

Rückgabe der UMS-Connection

getUmsPort

public int getUmsPort()

Rückgabe des IP-Ports für die UMS-Connection

getUserCode

public int getUserCode()

Rückgabe des Fehlercodes

getUserData

public String getUserData()

Rückgabe der User-Daten als String. Nach einem Connect enthalten die User-Daten zum Beispiel den Namen des TCP_TAN-Prozesses zu dem die Verbindung besteht.

Returns:

Die zuletzt empfangenen User-Daten

getUserData

public int getUserData(byte[] dst,
                       int offset,
                       int maxlen)
                throws CommException

Rückgabe der User-Daten. Die Anzahl der kopierten Bytes wird zurückgegeben Sind weniger Daten vorhanden als angefordert, wird der Rest mit Space gefüllt Nach einem Connect enthalten die User-Daten zum Beispiel den Namen des TCP_TAN-Prozesses zu dem die Verbindung besteht

Parameters:

dst - Zielbereich für die Daten

offset - Offset innerhalb von dst

maxlen - Maximale Länge

Returns:

Anzahl der kopierten Zeichen

Throws:

CommException - Allgemeiner Kommunikationsfehler

getUserLen

public int getUserLen()

Rückgabe der Länge der User-Daten

getUserObject

public Object getUserObject()

Zugriff auf das User-Objekt

Returns:

das User-Objekt

See Also:

setUserObject(java.lang.Object)

getUserOffset

public int getUserOffset()

Rückgabe des Offsets der User-Daten

isConnected

public boolean isConnected()

Rückgabe des Verbindungsstatus

isDebug

public boolean isDebug()

Rückgabe des Debug-Status

isNowait

public boolean isNowait()

Rückgabe des Nowait-Status

isTransaction

public boolean isTransaction()

Rückgabe des Transaktionsstatus

main

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

Test

Throws:

CommException

makeUmsDest

protected String makeUmsDest(String terminal,
                             String alias,
                             int reply_len)

Konstruiere die spezielle UMS-Destination

Parameters:

terminal - UMS-Terminalname

alias - UMS-Aliasname

reply_len - Maximale Länge der Antwort

Returns:

Destination

notImplemented

public void notImplemented(String caller)
                    throws CommException

Wirf CommException NOT_IMPLEMENTED

Parameters:

caller - Aufrufende Funktion

Throws:

CommException - nicht implementierte Funktion

println

public void println(Object text)

Debugging

receiveBuffer

public void receiveBuffer()
                   throws CommException,
                          TandemException

Empfangen der Antwort in io_buffer. Der Puffer wird nach einigen Kriterien ausgewertet. Parameter finden danach sich in den Member-Variablen des Objektes.

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

rollbackTransaction

public void rollbackTransaction()
                         throws CommException,
                                TandemException

Zurücknehmen einer Transaktion.

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

sendAccept

protected void sendAccept(int port)
                   throws CommException,
                          TandemException

Accept-Nachricht.

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

sendBuffer

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

Senden eines beliebigen Puffers. Für transparentes Pooling.

Parameters:

buffer - Daten

length - Länge der Daten

Throws:

CommException - Allgemeiner Kommunikationsfehler

sendBuffer

protected void sendBuffer(String tag,
                          int len,
                          int opt)
                   throws CommException

Senden einer Nachricht. Die Nachricht steht schon in io_buffer.

Parameters:

tag - Nachrichten-Tag ("INIT", "DATA", ...)

len - Länge der Nutzdaten ohne Header

opt - Options-Flag

Throws:

CommException - Allgemeiner Kommunikationsfehler

sendInit

protected void sendInit(String init)
                 throws CommException,
                        TandemException

Init-Nachricht.

Parameters:

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

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

sendMessage

protected int sendMessage(String dest)
                   throws CommException,
                          TandemException

Message an Server. Daten sind schon in io_buffer.

Parameters:

dest - Name des Servers

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

sendMessage

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

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

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

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

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.

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

sendMessage

protected int sendMessage(String dest,
                          int timeout)
                   throws CommException,
                          TandemException

Message an Server mit Timeout. Daten sind schon in io_buffer.

Parameters:

dest - Name des Servers

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

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

sendMessage

public int sendMessage(String dest,
                       MessageElement[] msg,
                       MessageElement[] reply)
                throws CommException,
                       TandemException

Message an Server. Message und Antwort als Array von MessageElement-Objekten.

Parameters:

dest - Name des Servers

msg - Message (Eingabe)

reply - Antwort (Ausgabe)

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

sendMessage

public int sendMessage(String dest,
                       MessageElement[] msg,
                       MessageElement[] reply,
                       int timeout)
                throws CommException,
                       TandemException

Message an Server mit Timeout. Message und Antwort als Array von MessageElement-Objekten.

Parameters:

dest - Name des Servers

msg - Message (Eingabe)

reply - Antwort (Ausgabe)

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

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

sendMessage

public int sendMessage(String dest,
                       MessageElement msg,
                       int msg_len,
                       MessageElement reply)
                throws CommException,
                       TandemException

Message an Server. Message und Antwort in getrennten MessageElement-Objekten. Angabe der Länge der zu sendenden Message

Parameters:

dest - Name des Servers

msg - Message (Eingabe)

msg_len - Länge der Message

reply - Antwort (Ausgabe)

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

sendMessage

public int sendMessage(String dest,
                       MessageElement msg,
                       int msg_len,
                       MessageElement reply,
                       int timeout)
                throws CommException,
                       TandemException

Message an Server mit Timeout. Message und Antwort in getrennten MessageElement-Objekten. Angabe der Länge der zu sendenden Message

Parameters:

dest - Name des Servers

msg - Message (Eingabe)

msg_len - Länge der Message

reply - Antwort (Ausgabe)

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

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

sendMessage

public int sendMessage(String dest,
                       MessageElement msg,
                       MessageElement reply)
                throws CommException,
                       TandemException

Message an Server. Message und Antwort in getrennten MessageElement-Objekten.

Parameters:

dest - Name des Servers

msg - Message (Eingabe)

reply - Antwort (Ausgabe)

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

TandemException - Tandem-Fehler

sendMessage

public int sendMessage(String dest,
                       MessageElement msg,
                       MessageElement reply,
                       int timeout)
                throws CommException,
                       TandemException

Message an Server mit Timeout. Message und Antwort in getrennten MessageElement-Objekten.

Parameters:

dest - Name des Servers

msg - Message (Eingabe)

reply - Antwort (Ausgabe)

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.

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.

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

sendUms

public int sendUms(String terminal,
                   String alias,
                   MessageElement msg,
                   int msg_len,
                   MessageElement reply)
            throws CommException

Message an UMS-Client. Message und Antwort in getrennten MessageElement-Objekten. Angabe der Länge der zu sendenden Message

Parameters:

terminal - UMS-Terminalname

alias - UMS-Aliasname

msg - Message (Eingabe)

msg_len - Länge der Message

reply - Antwort (Ausgabe)

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

sendUms

public int sendUms(String terminal,
                   String alias,
                   MessageElement msg,
                   MessageElement reply)
            throws CommException

Message an UMS-Client. Message und Antwort in getrennten MessageElement-Objekten.

Parameters:

terminal - UMS-Terminalname

alias - UMS-Aliasname

msg - Message (Eingabe)

reply - Antwort (Ausgabe)

Returns:

Anzahl der Zeichen in der Antwort

Throws:

CommException - Allgemeiner Kommunikationsfehler

setDebug

public boolean setDebug(boolean debug)

Setzen des Debug-Status

Parameters:

debug - Debug-Status

Returns:

der vorherige Stand

setDebugStream

public void setDebugStream(PrintWriter stream)

Setzen des debugStream und Debug-Status

Parameters:

stream - Ausgabe-Stream für Debugausgaben

setDebugStream

public void setDebugStream(String file)

Setzen des debugStream und Debug-Status

Parameters:

file - Dateiname für Debugausgaben

setUserObject

public void setUserObject(Object obj)

Speichern eines User-Objektes

Solche Objekte können zum Beispiel Puffer enthalten die pro Verbindung (in einem Pool) nur einmal erzeugt werden sollen

Beispiel:

      conn = pool.getConnection( timeout );
      MyMessage msg = (MyMessage) conn.getUserObject();
      if ( msg == null ) {
          msg = new MyMessage();
          conn.setUserObject( msg );
      }
  

Parameters:

obj - Das Objekt

singleTransaction

public void singleTransaction(int success_lo,
                              int success_hi)
                       throws CommException,
                              TandemException

Automatische Einzeltransaktion. singleTransaction funktioniert wie autoCommitTransaction, startet aber zusätzlich eine Transaktion vor dem nächsten sendMessage().

Parameters:

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

See Also:

sendMessage(java.lang.String, janus.util.MessageElement, janus.util.MessageElement), autoCommitTransaction(int, int), isTransaction()

tcpRead

protected void tcpRead(int offset,
                       int len)
                throws CommException

Empfangen einer definierten Anzahl von Bytes über die Socket-Verbindung.

Parameters:

offset - Position innerhalb von io_buffer

len - Anzahl der Bytes

Throws:

CommException - Allgemeiner Kommunikationsfehler

tcpWrite

protected void tcpWrite()
                 throws CommException

Senden des Puffers über die Socket-Verbindung.

Throws:

CommException - Allgemeiner Kommunikationsfehler

toString

public String toString()

Stringdarstellung

Overrides:

toString in class Object