marksl / dotnetflumeng.clients Goto Github PK

Hi,
I have issues getting things to work.
When I start up flume, my log says:

07 Jul 2014 14:41:02,966 INFO agent-shutdown-hook - Configuration provider stopping
07 Jul 2014 14:41:08,122 INFO lifecycleSupervisor-1-0 - Configuration provider starting
07 Jul 2014 14:41:08,122 INFO conf-file-poller-0 - Reloading configuration file:C:\Program Files\apache-flume-1.6.0-SNAPSHOT-bin\conf\flume2.conf
07 Jul 2014 14:41:08,138 INFO conf-file-poller-0 - Processing:Console
07 Jul 2014 14:41:08,138 INFO conf-file-poller-0 - Processing:Console
07 Jul 2014 14:41:08,138 INFO conf-file-poller-0 - Added sinks: Console Agent: agent
07 Jul 2014 14:41:08,138 INFO conf-file-poller-0 - Post-validation flume configuration contains configuration for agents: [agent]
07 Jul 2014 14:41:08,138 WARN conf-file-poller-0 - No configuration found for this host:syslog-agent
07 Jul 2014 14:41:08,153 INFO conf-file-poller-0 - Starting new configuration:{ sourceRunners:{} sinkRunners:{} channels:{} }

When I run run my visual studio application an exception occurs when my program tries to log. The error message is like that:

•   $exception  {"No connection could be established, connection denied to 127.0.0.1:9090"} System.Exception {System.Net.Sockets.SocketException}
  

Any ideas what I am doing wrong?

Best
Oliver

diff --git a/DotNetFlumeNG.Client.NLog/NLog/NLogEventAdapter.cs b/DotNetFlumeNG.Client.NLog/NLog/NLogEventAdapter.cs
index 5dffdc7..eabf0f3 100644
--- a/DotNetFlumeNG.Client.NLog/NLog/NLogEventAdapter.cs
+++ b/DotNetFlumeNG.Client.NLog/NLog/NLogEventAdapter.cs
@@ -28,13 +28,14 @@ public class NLogEventAdapter : LogEvent
private readonly string _message;

     public NLogEventAdapter(string message, LogEventInfo logEventInfo)

•        : base(logEventInfo.TimeStamp)
  

•        : base(logEventInfo.TimeStamp.ToUniversalTime())
   {
       if (message == null) throw new ArgumentNullException("message");
       if (logEventInfo == null) throw new ArgumentNullException("logEventInfo");
  
       _message = message;
       _logEventInfo = logEventInfo;
  

  • }

   public override LogPriority Priority
  

  diff --git a/DotNetFlumeNG.Client.NLog/Thrift/ThriftFlumeEventAdapter.cs b/DotNetFlumeNG.Client.NLog/Thrift/ThriftFlumeEventAdapter.cs
  index a217e34..d0d0df7 100644
  --- a/DotNetFlumeNG.Client.NLog/Thrift/ThriftFlumeEventAdapter.cs
  +++ b/DotNetFlumeNG.Client.NLog/Thrift/ThriftFlumeEventAdapter.cs
  @@ -19,6 +19,8 @@

  namespace DotNetFlumeNG.Client.Thrift
  {

• using System.Text;

public class ThriftFlumeEventAdapter : ThriftFlumeEvent
{
public ThriftFlumeEventAdapter(LogEvent logEvent)
@@ -70,9 +72,7 @@ private void SetFields(LogEvent logEvent)

 private static byte[] GetBytes(string str)
 {

•        var bytes = new byte[str.Length*sizeof (char)];
  

•        Buffer.BlockCopy(str.ToCharArray(), 0, bytes, 0, bytes.Length);
  

•        return bytes;
  

•        return Encoding.Default.GetBytes(str);
   }
  

  }
  }

• Set logtime to UTC

• default encoding, instead of unicode

An exception of type 'System.Net.Sockets.SocketException' occurred in System.dll but was not handled in user code

Additional information: No connection could be made because the target machine actively refused it

This exception cannot be captured by trycatch

For me userdomainname is not a valid hostname and timestamp is never set.

GetHostname might be better?

diff --git a/DotNetFlumeNG.Client.NLog/Core/LogEvent.cs b/DotNetFlumeNG.Client.NLog/Core/LogEvent.cs
index d26163c..4ea4545 100644
--- a/DotNetFlumeNG.Client.NLog/Core/LogEvent.cs
+++ b/DotNetFlumeNG.Client.NLog/Core/LogEvent.cs
@@ -47,8 +47,7 @@ public string Host
{
get
{

•            IPHostEntry he = Dns.GetHostEntry(Environment.UserDomainName);
  

•            return he.HostName;
  

•            return Dns.GetHostName();
       }
   }
  

diff --git a/DotNetFlumeNG.Client.NLog/NLog/NLogEventAdapter.cs b/DotNetFlumeNG.Client.NLog/NLog/NLogEventAdapter.cs
index b0b6d12..9607e4e 100644
--- a/DotNetFlumeNG.Client.NLog/NLog/NLogEventAdapter.cs
+++ b/DotNetFlumeNG.Client.NLog/NLog/NLogEventAdapter.cs
@@ -34,6 +34,8 @@ public NLogEventAdapter(string message, LogEventInfo logEventInfo)

         _message = message;
         _logEventInfo = logEventInfo;

•        this.Timestamp = logEventInfo.TimeStamp;
   }
  
   public override LogPriority Priority