Pipe
fun PipeSourceActiveMqBrokerParameters(batchSize: Int? = null, credentials: PipeMqBrokerAccessCredentialsProperties, maximumBatchingWindowInSeconds: Int? = null, queueName: String)