У меня есть следующий код в качестве модуля OSGi.
Когда он запускается, я получаю сообщение о том, что регистратор установлен:
UdpListener > setStoreLog: 'com.mine.logger.internal.storeindb.StoreLog@1c6f579'
Но сразу после этого циклв функции run () говорится, что storeLog пусто
ERROR > UdpListener > run > storeLog is not available.
Есть идеи, что может быть не так?
Может ли быть так, что это выполняется в потоке?
package com.mine.logger.internal.udp;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.util.Date;
import com.mine.logger.storeindb.IStoreLog;
public class UdpListener extends Thread
{
private int port;
private IStoreLog storeLog;
public void setStoreLog(IStoreLog value)
{
this.storeLog = value;
System.out.println("UdpListener > setStoreLog: '" + this.storeLog.toString() + "'");
}
public void unsetStoreLog(IStoreLog value)
{
if (this.storeLog == value) {
this.storeLog = null;
}
System.out.println("UdpListener > unsetStoreLog");
}
public UdpListener()
{
// public, no-args constructor needed for Declarative Services !!!
}
public UdpListener(int port)
{
this.port = port;
}
public void run()
{
startListener();
}
private void startListener()
{
try {
// send command
DatagramSocket socket = new DatagramSocket(port);
while (true)
{
byte[] b = new byte[1000];
DatagramPacket recvdPacket = new DatagramPacket(b, b.length);
socket.receive(recvdPacket);
System.out.println("UdpListener: Packet received. " + (new String(b)));
try
{
if (this.storeLog != null)
this.storeLog.doStore(new Date(), InetAddress.getByName("0.0.0.0"), port, 1, "UDP", b);
else
System.err.println("ERROR > UdpListener > run > storeLog is not available.");
}
catch (Exception e)
{
System.err.println("ERROR > UdpListener > run > storeLog > Exception: " + e.toString());
}
}
} catch (SocketException e) {
System.out.println("ERROR > UdpListener > run > SocketException: " + e.getMessage());
} catch (IOException e) {
System.out.println("ERROR > UdpListener > run > IOException: " + e.getMessage());
} catch (Exception e) {
System.out.println("ERROR > UdpListener > run > Exception: " + e.getMessage());
}
}
}