Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Accenture/mercury
/ functions
Functions
2,050 in github.com/Accenture/mercury
⨍
Functions
2,050
◇
Types & classes
398
↓ 3 callers
Method
touch
()
system/platform-core/src/main/java/org/platformlambda/automation/models/AsyncContextHolder.java:67
↓ 3 callers
Method
waitForProviders
This method may be used during application startup. @param providers route names of services that you want to check if they are ready @param seconds
system/platform-core/src/main/java/org/platformlambda/core/system/Platform.java:716
↓ 3 callers
Method
write
(Object map)
system/platform-core/src/main/java/org/platformlambda/core/serializers/SimpleXmlWriter.java:37
↓ 2 callers
Method
addParameter
(String key, Object value)
extensions/simple-scheduler/src/main/java/org/platformlambda/quartz/models/ScheduledJob.java:49
↓ 2 callers
Method
addRouteSubstitution
(String entry, String original, String replacement)
system/platform-core/src/main/java/org/platformlambda/core/system/EventEmitter.java:304
↓ 2 callers
Method
canIgnore
(String attributeName)
system/platform-core/src/main/java/org/platformlambda/core/serializers/SimpleXmlParser.java:232
↓ 2 callers
Method
checkExpiredStreams
()
system/platform-core/src/main/java/org/platformlambda/core/system/ObjectStreamIO.java:137
↓ 2 callers
Method
cleanUp
()
system/platform-core/src/main/java/org/platformlambda/core/util/ManagedCache.java:151
↓ 2 callers
Method
close
()
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncMultiInbox.java:101
↓ 2 callers
Method
close
()
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncInbox.java:91
↓ 2 callers
Method
closeConsumers
()
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/reporter/PresenceConnector.java:319
↓ 2 callers
Method
closeStalledConnection
(WsMetadata md, String reason)
connectors/core/service-monitor/src/main/java/org/platformlambda/ws/MonitorService.java:159
↓ 2 callers
Method
constructTrackedObject
(Node node, Object value)
system/rest-spring-2/src/main/java/org/platformlambda/spring/patch/OriginTrackedYamlLoader.java:113
↓ 2 callers
Method
createStream
()
system/platform-core/src/main/java/org/platformlambda/core/system/ObjectStreamIO.java:73
↓ 2 callers
Method
decodeQueryString
(String query)
system/platform-core/src/main/java/org/platformlambda/automation/util/SimpleHttpUtility.java:133
↓ 2 callers
Method
deleteTopic
(String topic)
system/platform-core/src/main/java/org/platformlambda/core/models/PubSubProvider.java:36
↓ 2 callers
Method
doLoopbackTest
(EventEnvelope input, String topicPartition, String message)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/CloudHealthCheck.java:121
↓ 2 callers
Method
dsaSign
Create a digital signature using a private key (DSA) @param data bytes @param privateKey encoded key @return signature @throws GeneralSecurityExceptio
system/platform-core/src/main/java/org/platformlambda/core/util/CryptoApi.java:223
↓ 2 callers
Method
dsaVerify
Verify a digital signature using a public key (DSA) @param data bytes @param signature bytes @param publicKey encoded public key @return true if signa
system/platform-core/src/main/java/org/platformlambda/core/util/CryptoApi.java:239
↓ 2 callers
Method
encodeList
(List<Object> objects, boolean binary)
system/platform-core/src/main/java/org/platformlambda/core/serializers/PayloadMapper.java:62
↓ 2 callers
Method
encodeTraceAnnotations
(EventEnvelope response)
system/platform-core/src/main/java/org/platformlambda/core/system/WorkerHandler.java:355
↓ 2 callers
Method
encodeUri
(String uri)
system/platform-core/src/main/java/org/platformlambda/automation/http/AsyncHttpClient.java:397
↓ 2 callers
Method
evaluate
(String statement)
system/platform-core/src/main/java/org/platformlambda/core/util/Feature.java:54
↓ 2 callers
Method
exceptionHandler
(Handler<Throwable> handler)
system/platform-core/src/main/java/org/platformlambda/automation/models/OutputStreamQueue.java:39
↓ 2 callers
Method
exists
(List<String> routes)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/ServiceQuery.java:132
↓ 2 callers
Method
exists
Check if a function with the named route exists @param route name @return true or false
system/platform-core/src/main/java/org/platformlambda/core/system/PostOffice.java:153
↓ 2 callers
Method
filterHeaders
(HeaderInfo headerInfo, Map<String, String> headers)
system/platform-core/src/main/java/org/platformlambda/automation/util/SimpleHttpUtility.java:95
↓ 2 callers
Method
generateDsaKey
()
system/platform-core/src/main/java/org/platformlambda/core/util/CryptoApi.java:204
↓ 2 callers
Method
getAddress
()
connectors/adapters/kafka/kafka-standalone/src/test/java/org/platformlambda/core/util/models/PoJo.java:43
↓ 2 callers
Method
getAddress
()
connectors/adapters/kafka/kafka-presence/src/test/java/org/platformlambda/core/util/models/PoJo.java:43
↓ 2 callers
Method
getAddress
()
connectors/adapters/kafka/kafka-connector/src/test/java/org/platformlambda/core/util/models/PoJo.java:43
↓ 2 callers
Method
getAddress
()
connectors/adapters/hazelcast/hazelcast-connector/src/test/java/org/platformlambda/core/util/models/PoJo.java:43
↓ 2 callers
Method
getAddress
()
connectors/adapters/hazelcast/hazelcast-presence/src/test/java/org/platformlambda/core/util/models/PoJo.java:43
↓ 2 callers
Method
getAssignedTopics
()
connectors/core/service-monitor/src/main/java/org/platformlambda/services/TopicController.java:269
↓ 2 callers
Method
getAuthService
(String headerKey)
system/platform-core/src/main/java/org/platformlambda/automation/models/RouteInfo.java:41
↓ 2 callers
Method
getBigDecimal
()
system/platform-core/src/test/java/org/platformlambda/core/models/PoJo.java:103
↓ 2 callers
Method
getBigInteger
()
system/platform-core/src/test/java/org/platformlambda/core/models/PoJo.java:95
↓ 2 callers
Method
getClassByName
(String name)
system/platform-core/src/main/java/org/platformlambda/core/serializers/PayloadMapper.java:143
↓ 2 callers
Method
getClassList
(Set<Class<?>> classes)
system/rest-spring-2/src/main/java/org/platformlambda/rest/RestLoader.java:136
↓ 2 callers
Method
getClientOptions
(boolean trustAll)
system/platform-core/src/main/java/org/platformlambda/automation/http/AsyncHttpClient.java:137
↓ 2 callers
Method
getCloudOrigins
()
system/platform-core/src/main/java/org/platformlambda/core/system/EventEmitter.java:159
↓ 2 callers
Method
getCloudRoutes
()
system/platform-core/src/main/java/org/platformlambda/core/system/EventEmitter.java:155
↓ 2 callers
Method
getClusterProperties
(String location)
connectors/adapters/hazelcast/hazelcast-connector/src/main/java/org/platformlambda/hazelcast/HazelcastConnector.java:68
↓ 2 callers
Method
getContent
()
connectors/adapters/kafka/kafka-standalone/src/test/java/org/platformlambda/core/util/models/ObjectWithGenericType.java:26
↓ 2 callers
Method
getContexts
()
system/platform-core/src/main/java/org/platformlambda/automation/services/ServiceGateway.java:160
↓ 2 callers
Method
getCookies
()
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:264
↓ 2 callers
Method
getCorsInfo
(String id)
system/platform-core/src/main/java/org/platformlambda/automation/config/RoutingEntry.java:141
↓ 2 callers
Method
getDefaultTraceIdLabel
()
system/platform-core/src/main/java/org/platformlambda/automation/services/ServiceGateway.java:156
↓ 2 callers
Method
getDeliveryError
()
system/platform-core/src/main/java/org/platformlambda/core/models/ProcessStatus.java:44
↓ 2 callers
Method
getDestinations
(String route)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/ServiceRegistry.java:133
↓ 2 callers
Method
getDisplayUrl
()
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/ConnectorConfig.java:71
↓ 2 callers
Method
getException
()
system/platform-core/src/main/java/org/platformlambda/core/models/ProcessStatus.java:82
↓ 2 callers
Method
getExecutionTime
()
system/platform-core/src/main/java/org/platformlambda/core/models/ProcessStatus.java:54
↓ 2 callers
Method
getFileName
()
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:213
↓ 2 callers
Method
getFunction
()
system/platform-core/src/main/java/org/platformlambda/core/system/ServiceDef.java:128
↓ 2 callers
Method
getFuture
()
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncInbox.java:72
↓ 2 callers
Method
getFutureEvents
Get future events for a target @param to target @return event ID list
system/platform-core/src/main/java/org/platformlambda/core/system/EventEmitter.java:600
↓ 2 callers
Method
getHeaderCase
(String header)
system/platform-core/src/main/java/org/platformlambda/automation/services/ServiceGateway.java:792
↓ 2 callers
Method
getHeaderCase
(String header)
system/platform-core/src/main/java/org/platformlambda/automation/util/SimpleHttpUtility.java:82
↓ 2 callers
Method
getHmac
(byte[] key, byte[] message, String algorithm)
system/platform-core/src/main/java/org/platformlambda/core/util/CryptoApi.java:423
↓ 2 callers
Method
getHmacSha1
(byte[] key, byte[] message)
system/platform-core/src/main/java/org/platformlambda/core/util/CryptoApi.java:415
↓ 2 callers
Method
getHmacSha256
(byte[] key, byte[] message)
system/platform-core/src/main/java/org/platformlambda/core/util/CryptoApi.java:419
↓ 2 callers
Method
getIndexes
(String indexSegment)
system/platform-core/src/main/java/org/platformlambda/core/util/MultiLevelMap.java:340
↓ 2 callers
Method
getInputStreamId
()
system/platform-core/src/main/java/org/platformlambda/automation/models/StreamHolder.java:51
↓ 2 callers
Method
getInstance
(String name)
system/platform-core/src/main/java/org/platformlambda/core/util/SimpleCache.java:84
↓ 2 callers
Method
getInstances
Retrieve all PubSub instances @return map of instances
system/platform-core/src/main/java/org/platformlambda/core/system/PubSub.java:72
↓ 2 callers
Method
getIv
IV does not need to be truly random. Therefore, we use the basic pseudo-random generator for performance reason. @return random value of 16 bytes
system/platform-core/src/main/java/org/platformlambda/core/util/CryptoApi.java:354
↓ 2 callers
Method
getLocalRoutingTable
Internal API that returns local routing table @return routing table
system/platform-core/src/main/java/org/platformlambda/core/system/Platform.java:329
↓ 2 callers
Method
getMethod
(String method)
system/platform-core/src/main/java/org/platformlambda/automation/http/AsyncHttpClient.java:214
↓ 2 callers
Method
getMonitorType
(String origin)
connectors/core/service-monitor/src/main/java/org/platformlambda/services/TopicController.java:119
↓ 2 callers
Method
getName
()
connectors/adapters/kafka/kafka-connector/src/test/java/org/platformlambda/core/util/models/PoJo.java:35
↓ 2 callers
Method
getName
()
connectors/adapters/hazelcast/hazelcast-connector/src/test/java/org/platformlambda/core/util/models/PoJo.java:35
↓ 2 callers
Method
getName
()
connectors/adapters/hazelcast/hazelcast-presence/src/test/java/org/platformlambda/core/util/models/PoJo.java:35
↓ 2 callers
Method
getNumber
()
connectors/adapters/kafka/kafka-standalone/src/test/java/org/platformlambda/core/util/models/PoJo.java:27
↓ 2 callers
Method
getNumber
()
connectors/adapters/kafka/kafka-presence/src/test/java/org/platformlambda/core/util/models/PoJo.java:27
↓ 2 callers
Method
getNumber
()
connectors/adapters/kafka/kafka-connector/src/test/java/org/platformlambda/core/util/models/PoJo.java:27
↓ 2 callers
Method
getNumber
()
connectors/adapters/hazelcast/hazelcast-connector/src/test/java/org/platformlambda/core/util/models/PoJo.java:27
↓ 2 callers
Method
getNumber
()
connectors/adapters/hazelcast/hazelcast-presence/src/test/java/org/platformlambda/core/util/models/PoJo.java:27
↓ 2 callers
Method
getNumericValue
(char c)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:955
↓ 2 callers
Method
getParametricType
()
system/platform-core/src/main/java/org/platformlambda/core/models/TypedPayload.java:45
↓ 2 callers
Method
getProperties
()
connectors/adapters/kafka/kafka-connector/src/main/java/org/platformlambda/kafka/services/PubSubManager.java:81
↓ 2 callers
Method
getRandomBytes
Pseudo random generator. Note that this is not cryptographically secure. Therefore, do not use this to generate AES encryption key. @param len of ran
system/platform-core/src/main/java/org/platformlambda/core/util/CryptoApi.java:515
↓ 2 callers
Method
getRemoteIp
()
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:101
↓ 2 callers
Method
getResponseBodyAsPoJo
Convert the event response body into a PoJo @param response event @param toValueType class @return pojo @param <T> pojo class
system/platform-core/src/main/java/org/platformlambda/core/system/PostOffice.java:135
↓ 2 callers
Method
getSample
()
system/platform-core/src/test/java/org/platformlambda/core/GsonTest.java:77
↓ 2 callers
Method
getServiceName
()
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/ConnectorConfig.java:67
↓ 2 callers
Method
getSqlTimestamp
(java.sql.Timestamp time)
system/platform-core/src/main/java/org/platformlambda/core/util/Utility.java:343
↓ 2 callers
Method
getStatus
()
system/platform-core/src/main/java/org/platformlambda/core/models/ProcessStatus.java:78
↓ 2 callers
Method
getSubscribers
(String topic)
system/platform-core/src/main/java/org/platformlambda/core/system/LocalPubSub.java:83
↓ 2 callers
Method
getTargetHost
()
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:341
↓ 2 callers
Method
getTopic
(String dest)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/ServiceRegistry.java:146
↓ 2 callers
Method
getTopic
(String topicPartition)
connectors/core/cloud-connector/src/main/java/org/platformlambda/cloud/services/CloudHealthCheck.java:154
↓ 2 callers
Method
getTopic
(String origin)
connectors/core/service-monitor/src/main/java/org/platformlambda/services/TopicController.java:123
↓ 2 callers
Method
getTopics
()
system/platform-core/src/main/java/org/platformlambda/core/system/LocalPubSub.java:75
↓ 2 callers
Method
getTraceId
Get X-Trace-Id from HTTP request headers if any. Otherwise, generate a unique ID. @param request HTTP @return traceLabel and traceId
system/platform-core/src/main/java/org/platformlambda/automation/services/ServiceGateway.java:776
↓ 2 callers
Method
getType
()
system/platform-core/src/main/java/org/platformlambda/core/models/EventEnvelope.java:211
↓ 2 callers
Method
getTypedPayload
(Object obj, boolean binary)
system/platform-core/src/main/java/org/platformlambda/core/serializers/PayloadMapper.java:99
↓ 2 callers
Method
getUploadTag
()
system/platform-core/src/main/java/org/platformlambda/core/models/AsyncHttpRequest.java:323
↓ 2 callers
Method
getWebSocket
()
system/platform-core/src/main/java/org/platformlambda/core/websocket/server/WsEnvelope.java:74
↓ 2 callers
Method
handle
(boolean resume, HttpServletRequest request, HttpServletResponse response)
system/rest-spring-3/src/main/java/org/platformlambda/servlets/SuspendResume.java:41
← previous
next →
401–500 of 2,050, ranked by callers