Lösung für das Timeout-Problem der SNMP4J-Serververbindung

	/**
	 * Sendet eine SNMP-Nachricht an die angegebene Adresse.
	 * 
	 * @param Adresse
	 * eine <code>TcpAddress</code>. Eine
	 * <code>ClassCastException</code> wird geworfen, wenn
	 * <code>Adresse</code> ist keine <code>TcpAddress</code>
	 * Instanz.
	 * @param Nachricht
	 * byte[] die zu sendende Nachricht.
	 * @throws IOException
	 */
	public void sendMessage(Adresse Adresse, Byte[] Nachricht)
			wirft java.io.IOException {
		wenn (server == null) {
			Hören();
		}
		serverThread.sendMessage(Adresse, Nachricht);
	}

	public void sendMessage(Adresse Adresse, Byte[] Nachricht)
			wirft java.io.IOException {
		Sockel s = null;
		SocketEntry-Eintrag = (SocketEntry) sockets.get(Adresse);
		wenn (logger.isDebugEnabled()) {
			logger.debug("Suche nach Verbindung für Ziel '"
					+ Adresse + "' zurückgegeben: " + Eintrag);
			logger.debug(sockets.toString());
		}
		wenn (Eintrag != null) {
			s = Eintrag.getSocket();
		}
		wenn ((s == null) || (s.isClosed()) || (!s.isConnected())) {
			wenn (logger.isDebugEnabled()) {
				logger.debug("Socket für Adresse '" + Adresse
						+ "' ist geschlossen, beim Öffnen...");
			}
			ausstehend.entfernen(Eintrag);
			SocketChannel sc = null;
			versuchen {
				//Öffne den Kanal, stelle ihn auf nicht blockierend ein, initiiere
				// verbinden
				sc = SocketChannel.open();
				sc.configureBlocking(false);
				sc
						.connect(neue InetSocketAdresse(
								((TcpAddress) Adresse).getInetAddress(),
								((TcpAddress) Adresse).getPort()));
				s = sc.socket();
				Eintrag = neuer SocketEntry((TcpAddress) Adresse, s);
				Eintrag.addMessage(Nachricht);
				sockets.put(Adresse, Eintrag);
	
				synchronisiert (ausstehend) {
					ausstehend.hinzufügen(Eintrag);
				}
	
				Selektor.wakeup();
				logger.debug("Verbindungsversuch mit " + Adresse);
			} Fang (IOException iox) {
				logger.fehler(iox);
				iox werfen;
			}
		} anders {
			Eintrag.addMessage(Nachricht);
			synchronisiert (ausstehend) {
				ausstehend.hinzufügen(Eintrag);
			}
			Selektor.wakeup();
		}
	}

private synchronisiert void timeoutSocket(SocketEntry entry) { 
  if (VerbindungsTimeout > 0) { 
    socketCleaner.schedule(neuer SocketTimeout(Eintrag), VerbindungsTimeout); 
  } 
}

private void init() wirft UnknownHostException, IOException { 
  ThreadPool = ThreadPool.create("Falle", 2); 
  Dispatcher = neuer MultiThreadedMessageDispatcher (ThreadPool, neuer MessageDispatcherImpl ()); 
  // Lokale IP und Abhörport listenAddress = GenericAddress.parse(System.getProperty("snmp4j.listenAddress", "tcp:192.168.9.69/5055")); 
  DefaultTcpTransportMapping-Transport; 
  transport = neue DefaultTcpTransportMapping((Tcp-Adresse) listenAdresse); 
  transport.setConnectionTimeout(0); 
  snmp = neues Snmp(Dispatcher, Transport); 
  snmp.getMessageDispatcher().addMessageProcessingModel(neues MPv1()); 
  snmp.getMessageDispatcher().addMessageProcessingModel(neues MPv2c()); 
  snmp.getMessageDispatcher().addMessageProcessingModel(neues MPv3()); 
  USM usm = neues USM(SecurityProtocols.getInstance(), neuer OctetString(MPv3.createLocalEngineID()), 0); 
  : SecurityModels.getInstance().addSecurityModel(usm); 
  snmp.listen(); 
}