Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

IGNITE-4539: RocketMQ Streamer implementation. #1571

Closed
wants to merge 8 commits into from
Closed

IGNITE-4539: RocketMQ Streamer implementation. #1571

Changes from 1 commit
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
b5c9318
IGNITE-4539: RocketMQ data streamer.
shroman Jan 26, 2017
dc2eed6
Changed RocketMQ version to the latest release.
shroman Feb 21, 2017
b8a69ab
IGNITE-4539: reworked RocketMQ startup.
shroman Feb 23, 2017
dadf826
Merger with master.
shroman Feb 23, 2017
0adfd27
IGNITE-4539: Reworked topic creation.
shroman Apr 19, 2017
77228ab
Merged with master.
shroman Apr 19, 2017
697bc5e
Updated RocketMQ dependencies.
shroman Apr 19, 2017
bdf1820
Broker scope to test.
shroman Apr 25, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 2 additions & 11 deletions modules/rocketmq/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -44,23 +44,14 @@

<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-client</artifactId>
<artifactId>rocketmq-broker</artifactId>
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I have checked your broker dependency is just for test. Could you scope this dependency to test ?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks! Modified.

<version>${rocketmq.version}</version>
</dependency>

<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-test</artifactId>
<artifactId>rocketmq-namesrv</artifactId>
<version>${rocketmq.version}</version>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-test</artifactId>
<version>${rocketmq.version}</version>
<type>test-jar</type>
<scope>test</scope>
</dependency>

<dependency>
Expand Down