XD-1737 Added --verbose option
XD-1741

Added StringToByteArrayConverter in app config

Added unicode chars to test
Fix Test Rabbit Queue Deletion

foo.props.0, xdbus:queue, xdbus:bar

Test for custom prefix left foo.props.

doTest was using the underlying Rabbit bus, not the wrapper.
XD-1742 Support Binary in TCP and HTTP Sources

JIRA: https://jira.spring.io/browse/XD-1742

Previously, the TCP and HTTP sources unconditionally
converted byte[] to String.

Remove the transformer from the tcp source; now, if people
want String conversion, they would use

    tcp --outputType=text/plain

Tested with

    stream create --name foo --definition "tcp --decoder=RAW | file --binary=true " --deploy
    stream create --name foo --definition "tcp --decoder=RAW --outputType=text/plain;charset=UTF-8 | file --binary=true " --deploy

Update the inbound http channel adapter to detect a
content-type of `application/octet-stream` and emit
a byte[] instead of performing String conversion.

This allows POSTing binary data...

    curl --data-binary @foo.zip -H'content-type: application/octet-stream' http://localhost:9000

Add test case to verify. Also tested with

    stream create --name bar --definition "http | file --binary=true " --deploy
Fixed compile warnings
XD-1672 filepollhdfs Acceptance Test

* Hdfs based tests will use assertValidHdfs
* Remove overloaded SimpleFileSink.toDSL method
* Replaced FileSourceTest's triggers with http
XD-1747: Module deployment order is not guaranteed

Modified writeDeployment to deploy each module serially (but still
write out deployment requests for a module to multiple containers
at once). This is required to guarantee that modules for a stream
are deployed in the correct order.
XD-1520 Update ModuleOptions stream name defaults

- Fix Module options that use stream name as the default value
  - Add ${xd.stream.name} as the default value in appropriate
module options POJO and module options properties
  - This will allow `module info` command to display the default values
with ${xd.stream.name} wherever stream name is used

Following modules are fixed:
File Sink
Gemfire sinks
Aggregator
File source
Metrics
HDFS dataset
Hdfs + move into own dir
Post
Tail
JMS
SimpleFileSink uses StringUtils.hasText to check for null and empty strings for the fileName and directory when creating DSL string.
JobPluginTests - Remove explicit datasource url

- Since this test uses hsqlDataSource which randomly gets configured
by `RandomConfigurationSupport` explicit datasource url is not needed.
XD-1757 Resolve runtime module option values

- Fix ZooKeeperModuleMetdataRepository's findOne(String metadataPath)
   - Check if the module option value has property placeholder syntax and retrieve
the placeholder value from module metadata from ZK metadata data
For example, if the `log` module's name option has the value ${xd.stream.name} then
look for `xd.stream.name` in module metadata to resolve the module option `name`
XD-1748 Spring Integration -> 4.0.1 + Spring IO

JIRA: https://jira.spring.io/browse/XD-1748

Spring Integration to 4.0.1 - performance improvement in
the aggregator for large groups (e.g. hdfs-dataset). Update
the sink to enable the improvement.

Also move other deps to Spring IO versions.

Hold back spring-data-redis, because 1.3.0 is not
compatible with boot 1.0.x.
XD-1758 Resets the amqUrl to amq.url for brokerUrl
XD-1756 Upgrading to SHDP 2.0 RC4, modifying configs to match new properties
WebUI: enable/disable schedule action

- Instead of show/hide the schedule button, use
`enable/disable` the button based on the validity
of the job trigger stream name and fixed delay number
XD-1310 JobExecution already running error msg

- Fix error message to use JobInstance (similar to what the container would throw)
- Update BatchJobExecutionsControllerIntegrationTests
XD-1338 RabbitMessageBus Paritioning Support

Producers use `partitionKeyExpression` and
`partitionExpression` (optional) applied to the
key. The modulo operation is then applied, with
the module count as the divisor.

If no `partitionExpression` is provided, the bus's
`PartitionStrategy` is invoked; the default strategy
returns `key.hashCode() % count`.

The resulting value is added to the message headers so
it can be used in the routing key expression.

Consumers use their 'partition' property to
determine which queue to listen to.

The deployment supervisor needs to add this
property for each module instance deployed,
such that there is at least one consumer for
each partition.

XD-1338 Producer Partitioning Straw Man

Polishing

Add moduleCount property; declare partition queues.

Pass partition properties (specifically, count) to consumer/producer.

Add Consumer Support

2nd commit message:
Polishing - Support Java Partitioning; PR Comments

If the module deployment properties contains
a class name (for the extractor or partitioner)
it is dynamically added as a bean to the context.

3rd commit message:
Fix Typo in ParameterName

s/partioner/partitioner/

4th commit message:
Polishing - Rename to PartitionSelector
XD-1416 Activate tap only when 1 or more consumers