org.vishia.msgDispatch

Class MsgReceiver

java.lang.Object

org.vishia.msgDispatch.MsgReceiver

public class MsgReceiver
extends java.lang.Object

This class receives the messages from the target device, dispatch it per ident and writes it in the actual list and in some files. The message is dispatched using MsgDispatcher.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	MsgReceiver.MsgItem

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	bActivated true if the messages will be displayed.
private boolean	bListToBottom
(package private) InterProcessComm	comm
private Report	console
(package private) MsgConfig	msgConfig
private LogMessage	msgDispatcher The instance for dispatching the messages.
(package private) MsgItems_h.MsgItem	msgItem
(package private) java.util.List<MsgReceiver.MsgItem>	msgOfDay
(package private) int[]	nrofBytesReceived
(package private) MsgItems_h.MsgItems	recvData
(package private) byte[]	recvDataBuffer
(package private) static int	version Version, history and license.

Constructor Summary

Constructors

Constructor and Description
MsgReceiver(Report console, LogMessage msgDispatcher, MsgConfig msgConfig, InterProcessComm comm)

Method Summary

Modifier and Type	Method and Description
void	start() Now start work.
private void	storeMsgOfDay(long absTime, int ident, java.lang.Object... values)
(package private) void	test()
void	testAndReceive() This method should be called in a applications thread cyclically.

Methods inherited from class java.lang.Object

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

Field Detail

version

static final int version

Version, history and license.

• 2010-06-00 Hartmut created

Copyright/Copyleft: For this source the LGPL Lesser General Public License, published by the Free Software Foundation is valid. It means:

1. You can use this source without any restriction for any desired purpose.
2. You can redistribute copies of this source to everybody.
3. Every user of this source, also the user of redistribute copies with or without payment, must accept this license for further using.
4. But the LPGL ist not appropriate for a whole software product, if this source is only a part of them. It means, the user must publish this part of source, but don't need to publish the whole source of the own product.
5. You can study and modify (improve) this source for own using or for redistribution, but you have to license the modified sources likewise under this LGPL Lesser General Public License. You mustn't delete this Copyright/Copyleft inscription in this source file.

If you are indent to use this sources without publishing its usage, you can get a second license subscribing a special contract with the author.

See Also:

Constant Field Values

msgConfig

final MsgConfig msgConfig

console

private final Report console

bActivated

private boolean bActivated

true if the messages will be displayed. Only then it will be got from receiver.

bListToBottom

private boolean bListToBottom

msgOfDay

java.util.List<MsgReceiver.MsgItem> msgOfDay

comm

final InterProcessComm comm

msgDispatcher

private final LogMessage msgDispatcher

The instance for dispatching the messages.

recvData

final MsgItems_h.MsgItems recvData

recvDataBuffer

final byte[] recvDataBuffer

nrofBytesReceived

final int[] nrofBytesReceived

msgItem

MsgItems_h.MsgItem msgItem

Constructor Detail

MsgReceiver

public MsgReceiver(Report console,
                   LogMessage msgDispatcher,
                   MsgConfig msgConfig,
                   InterProcessComm comm)

Method Detail

start

public void start()

Now start work.

storeMsgOfDay

private void storeMsgOfDay(long absTime,
                           int ident,
                           java.lang.Object... values)

test

void test()

testAndReceive

public void testAndReceive()

This method should be called in a applications thread cyclically. It tests whether new datagram with messages is received. Note: The method does not block, because the comm.InterProcessComm.open(org.vishia.communication.Address_InterProcessComm, boolean) should be called for non blocking mode!