Skip to content

Commit 9518f19

Browse files
conker84moxious
authored andcommitted
fixes #270: Change Procedure Mode (#271)
1 parent 0fbf715 commit 9518f19

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

consumer/src/main/kotlin/streams/procedures/StreamsSinkProcedures.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ class StreamsSinkProcedures {
1515
@JvmField @Context
1616
var log: Log? = null
1717

18-
@Procedure(mode = Mode.SCHEMA, name = "streams.consume")
18+
@Procedure(mode = Mode.READ, name = "streams.consume")
1919
@Description("streams.consume(topic, {timeout: <long value>, from: <string>, groupId: <string>, commit: <boolean>, partitions:[{partition: <number>, offset: <number>}]}) " +
2020
"YIELD event - Allows to consume custom topics")
2121
fun consume(@Name("topic") topic: String?,

producer/src/main/kotlin/streams/procedures/StreamsProcedures.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ class StreamsProcedures {
1212

1313
@JvmField @Context var log: Log? = null
1414

15-
@Procedure(mode = Mode.SCHEMA, name = "streams.publish")
15+
@Procedure(mode = Mode.READ, name = "streams.publish")
1616
@Description("streams.publish(topic, config) - Allows custom streaming from Neo4j to the configured stream environment")
1717
fun publish(@Name("topic") topic: String?, @Name("payload") payload: Any?,
1818
@Name(value = "config", defaultValue = "{}") config: Map<String, Any>?) {

0 commit comments

Comments
 (0)