Skip to content

Commit

Permalink
Update scalafmt-core to 3.7.3 (#98)
Browse files Browse the repository at this point in the history
* Update scalafmt-core to 3.7.3

* Reformat with scalafmt 3.7.3

Executed command: scalafmt --non-interactive

* Add 'Reformat with scalafmt 3.7.3' to .git-blame-ignore-revs

---------

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
  • Loading branch information
scala-steward and github-actions[bot] committed May 18, 2023
1 parent bf38fbb commit 4869e03
Show file tree
Hide file tree
Showing 3 changed files with 16 additions and 16 deletions.
3 changes: 3 additions & 0 deletions .git-blame-ignore-revs
Original file line number Diff line number Diff line change
@@ -1,2 +1,5 @@
# Scala Steward: Reformat with scalafmt 3.7.1
efde41ddb9bf831725193a44c2a8b0d58c02fd0a

# Scala Steward: Reformat with scalafmt 3.7.3
f77f3ee8cce3027219cd3b16954caca84694856b
2 changes: 1 addition & 1 deletion .scalafmt.conf
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
runner.dialect = "scala213"
version = 3.7.1
version = 3.7.3
binPack.parentConstructors = true
maxColumn = 128
includeCurlyBraceInSelectChains = false
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,12 +8,11 @@ import ru.tinkoff.gatling.amqp.javaapi.protocol._

class AmqpGatlingTest extends Simulation {

val testQueue = new AmqpQueue("test_queue",true,false,false, java.util.Map.of())
val testExchange = new AmqpExchange("test_exchange", BuiltinExchangeType.TOPIC,true,false, java.util.Map.of())
val testQueue = new AmqpQueue("test_queue", true, false, false, java.util.Map.of())
val testExchange = new AmqpExchange("test_exchange", BuiltinExchangeType.TOPIC, true, false, java.util.Map.of())

setUp(
scenario("Test Scenario")
.exec{s => s.set("bytes", "RR topic test message".getBytes)}
scenario("Test Scenario").exec { s => s.set("bytes", "RR topic test message".getBytes) }
.exec(
amqp("Test publish queue exchange").publish
.queueExchange("test_queue")
Expand All @@ -27,7 +26,7 @@ class AmqpGatlingTest extends Simulation {
)
.exec(
amqp("Test publish topic exchange").publish
.topicExchange("test_exchange","routingKey")
.topicExchange("test_exchange", "routingKey")
.textMessage("Publish topic test message")
.priority(0)
.messageId("2")
Expand Down Expand Up @@ -55,7 +54,7 @@ class AmqpGatlingTest extends Simulation {
.messageId("4")
.check(
jsonPath("$.message").is("RR queue test message"),
jmesPath("message").is("RR queue test message")
jmesPath("message").is("RR queue test message"),
)
.asScala(),
)
Expand All @@ -68,7 +67,7 @@ class AmqpGatlingTest extends Simulation {
.priority(0)
.messageId("5")
.check(
bodyBytes.is("RR topic test message".getBytes)
bodyBytes.is("RR topic test message".getBytes),
)
.asScala(),
)
Expand All @@ -82,24 +81,23 @@ class AmqpGatlingTest extends Simulation {
.check(
simpleCheck(msg => msg.messageId.matches("6")),
bodyString.is("RR direct test message"),
substring("RR").exists()
substring("RR").exists(),
)
.asScala(),
)
.exec(
amqp("Test xpath check").requestReply
.directExchange("test_exchange", "routingKey")
.replyExchange("test_queue")
.textMessage(
"""
.textMessage("""
|<Request>
| <message>xpath check</message>
|</Request>
|""".stripMargin)
.priority(0)
.messageId("7")
.check(
xpath("""//Request/message""").is("xpath check")
xpath("""//Request/message""").is("xpath check"),
)
.asScala(),
)
Expand All @@ -117,14 +115,13 @@ class AmqpGatlingTest extends Simulation {
)
.declare(testExchange)
.declare(testQueue)
.bindQueue(testQueue, testExchange,"routingKey", java.util.Map.of())
.bindQueue(testQueue, testExchange, "routingKey", java.util.Map.of())
.replyTimeout(20000)
.consumerThreadsCount(1)
.usePersistentDeliveryMode()
.protocol(),
)
.maxDuration(20)
).maxDuration(20)
.assertions(
global.failedRequests.percent.is(0.0)
global.failedRequests.percent.is(0.0),
)
}

0 comments on commit 4869e03

Please sign in to comment.