|
|
@@ -53,7 +53,8 @@ class SocketHandler extends AbstractProcessingHandler
|
|
|
public function write(array $record)
|
|
|
{
|
|
|
$this->connectIfNotConnected();
|
|
|
- $this->writeToSocket((string) $record['formatted']);
|
|
|
+ $data = $this->generateDataStream($record);
|
|
|
+ $this->writeToSocket($data);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
@@ -227,6 +228,11 @@ class SocketHandler extends AbstractProcessingHandler
|
|
|
$this->connect();
|
|
|
}
|
|
|
|
|
|
+ protected function generateDataStream($record)
|
|
|
+ {
|
|
|
+ return (string) $record['formatted'];
|
|
|
+ }
|
|
|
+
|
|
|
private function connect()
|
|
|
{
|
|
|
$this->createSocketResource();
|