@@ -88,7 +88,10 @@ RemoteSyslogChannel::~RemoteSyslogChannel()
 void RemoteSyslogChannel::open()
 {
 	if (_open) return;
-	
+
+	// reset socket for the case that it has been previously closed
+	_socket = DatagramSocket();
+
 	if (_logHost.find(':') != std::string::npos)
 		_socketAddress = SocketAddress(_logHost);
 	else
@@ -105,6 +108,8 @@ void RemoteSyslogChannel::open()
 			_host = _socket.address().host().toString();
 		}
 	}
+
+	_open = true;
 }
 
 
 
@@ -167,6 +167,45 @@ void SyslogTest::testListener()
 }
 
 
+void SyslogTest::testChannelOpenClose()
+{
+	Poco::AutoPtr<RemoteSyslogChannel> channel = new RemoteSyslogChannel();
+	channel->setProperty("loghost", "localhost:51400");
+	channel->open();
+	Poco::AutoPtr<RemoteSyslogListener> listener = new RemoteSyslogListener(51400);
+	listener->open();
+	CachingChannel cl;
+	listener->addChannel(&cl);
+
+	assert (cl.getCurrentSize() == 0);
+	Poco::Message msg1("source1", "message1", Poco::Message::PRIO_CRITICAL);
+	channel->log(msg1);
+	Poco::Thread::sleep(1000);
+	assert (cl.getCurrentSize() == 1);
+
+	channel->close(); // close and re-open channel
+	channel->open();
+
+	Poco::Message msg2("source2", "message2", Poco::Message::PRIO_ERROR);
+	channel->log(msg2);
+	Poco::Thread::sleep(1000);
+	assert (cl.getCurrentSize() == 2);
+
+	listener->close();
+	std::vector<Poco::Message> msgs;
+	cl.getMessages(msgs, 0, 10);
+	assert (msgs.size() == 2);
+
+	assert (msgs[1].getSource() == "source1");
+	assert (msgs[1].getText() == "message1");
+	assert (msgs[1].getPriority() == Poco::Message::PRIO_CRITICAL);
+
+	assert (msgs[0].getSource() == "source2");
+	assert (msgs[0].getText() == "message2");
+	assert (msgs[0].getPriority() == Poco::Message::PRIO_ERROR);
+}
+
+
 void SyslogTest::testOldBSD()
 {
 	Poco::AutoPtr<RemoteSyslogChannel> channel = new RemoteSyslogChannel();
@@ -209,6 +248,7 @@ CppUnit::Test* SyslogTest::suite()
 	CppUnit::TestSuite* pSuite = new CppUnit::TestSuite("SyslogTest");
 
 	CppUnit_addTest(pSuite, SyslogTest, testListener);
+	CppUnit_addTest(pSuite, SyslogTest, testChannelOpenClose);
 	CppUnit_addTest(pSuite, SyslogTest, testOldBSD);
 
 	return pSuite;
 
@@ -47,6 +47,7 @@ class SyslogTest: public CppUnit::TestCase
 	~SyslogTest();
 
 	void testListener();
+	void testChannelOpenClose();
 	void testOldBSD();
 
 	void setUp();
Original file line number	Diff line number	Diff line change
`@@ -88,7 +88,10 @@ RemoteSyslogChannel::~RemoteSyslogChannel()`
`88`	`88`	`void RemoteSyslogChannel::open()`
`89`	`89`	`{`
`90`	`90`	`if (_open) return;`
`91`		`-`
	`91`	`+`
	`92`	`+ // reset socket for the case that it has been previously closed`
	`93`	`+ _socket = DatagramSocket();`
	`94`	`+`
`92`	`95`	`if (_logHost.find(':') != std::string::npos)`
`93`	`96`	`_socketAddress = SocketAddress(_logHost);`
`94`	`97`	`else`
`@@ -105,6 +108,8 @@ void RemoteSyslogChannel::open()`
`105`	`108`	`_host = _socket.address().host().toString();`
`106`	`109`	`}`
`107`	`110`	`}`
	`111`	`+`
	`112`	`+ _open = true;`
`108`	`113`	`}`
`109`	`114`
`110`	`115`