Package org.apache.camel.component.grok
Class GrokDataFormat
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.component.grok.GrokDataFormat
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.DataFormat
,org.apache.camel.spi.DataFormatName
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
@Dataformat("grok") public class GrokDataFormat extends org.apache.camel.support.service.ServiceSupport implements org.apache.camel.spi.DataFormat, org.apache.camel.spi.DataFormatName, org.apache.camel.CamelContextAware
-
-
Constructor Summary
Constructors Constructor Description GrokDataFormat()
GrokDataFormat(String pattern)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
doStart()
protected void
doStop()
org.apache.camel.CamelContext
getCamelContext()
String
getDataFormatName()
void
marshal(org.apache.camel.Exchange exchange, Object graph, OutputStream stream)
GrokDataFormat
registerPatternDefinition(String name, String pattern)
GrokDataFormat
registerPatternDefinition(GrokPattern pattern)
GrokDataFormat
setAllowMultipleMatchesPerLine(boolean allowMultipleMatchesPerLine)
void
setCamelContext(org.apache.camel.CamelContext camelContext)
GrokDataFormat
setFlattened(boolean flattened)
Sets the flattened mode flagGrokDataFormat
setNamedOnly(boolean namedOnly)
Whether to capture named expressions only or not (i.e.GrokDataFormat
setPattern(String pattern)
Object
unmarshal(org.apache.camel.Exchange exchange, InputStream stream)
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
-
-
Constructor Detail
-
GrokDataFormat
public GrokDataFormat(String pattern)
-
GrokDataFormat
public GrokDataFormat()
-
-
Method Detail
-
registerPatternDefinition
public GrokDataFormat registerPatternDefinition(GrokPattern pattern)
-
registerPatternDefinition
public GrokDataFormat registerPatternDefinition(String name, String pattern)
- Parameters:
name
- : Pattern Namepattern
- : Regular expression Or Grok pattern
-
setPattern
public GrokDataFormat setPattern(String pattern)
-
setFlattened
public GrokDataFormat setFlattened(boolean flattened)
Sets the flattened mode flag- Parameters:
flattened
- If true, conversion throws exception for conficting named matches.
-
setAllowMultipleMatchesPerLine
public GrokDataFormat setAllowMultipleMatchesPerLine(boolean allowMultipleMatchesPerLine)
-
setNamedOnly
public GrokDataFormat setNamedOnly(boolean namedOnly)
Whether to capture named expressions only or not (i.e. %{IP:ip} but not ${IP})
-
getDataFormatName
public String getDataFormatName()
- Specified by:
getDataFormatName
in interfaceorg.apache.camel.spi.DataFormatName
-
getCamelContext
public org.apache.camel.CamelContext getCamelContext()
- Specified by:
getCamelContext
in interfaceorg.apache.camel.CamelContextAware
-
setCamelContext
public void setCamelContext(org.apache.camel.CamelContext camelContext)
- Specified by:
setCamelContext
in interfaceorg.apache.camel.CamelContextAware
-
marshal
public void marshal(org.apache.camel.Exchange exchange, Object graph, OutputStream stream) throws Exception
- Specified by:
marshal
in interfaceorg.apache.camel.spi.DataFormat
- Throws:
Exception
-
unmarshal
public Object unmarshal(org.apache.camel.Exchange exchange, InputStream stream) throws Exception
- Specified by:
unmarshal
in interfaceorg.apache.camel.spi.DataFormat
- Throws:
Exception
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
-