- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 272 for eventbus (0.17 sec)
-
internal/event/target/amqp.go
confirmed := <-confirms if !confirmed.Ack { return fmt.Errorf("failed delivery of delivery tag: %d", confirmed.DeliveryTag) } } return nil } // Save - saves the events to the store which will be replayed when the amqp connection is active. func (target *AMQPTarget) Save(eventData event.Event) error { if target.store != nil { _, err := target.store.Put(eventData) return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10K bytes - Viewed (0) -
.github/workflows/codeql-analysis.yml
permissions: {} jobs: CodeQL-Build: permissions: actions: read # for github/codeql-action/init to get workflow details contents: read # for actions/checkout to fetch code security-events: write # for github/codeql-action/analyze to upload SARIF results runs-on: ubuntu-latest strategy: fail-fast: false matrix: # Override automatic language detection by changing the below list
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Fri Oct 11 18:32:33 UTC 2024 - 4K bytes - Viewed (0) -
internal/logger/target/testlogger/testlogger.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. // Package testlogger contains an autoregistering logger that can be used to capture logging events // for individual tests. // This package should only be included by test files. // To enable logging for a test, use: // // func TestSomething(t *testing.T) { // defer testlogger.T.SetLogTB(t)() //
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4K bytes - Viewed (0) -
internal/event/target/nats.go
if connErr.Error() == nats.ErrNoServers.Error() { return false, store.ErrNotConnected } return false, connErr } } return true, nil } // Save - saves the events to the store which will be replayed when the Nats connection is active. func (target *NATSTarget) Save(eventData event.Event) error { if target.store != nil { _, err := target.store.Put(eventData) return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 12.9K bytes - Viewed (0) -
internal/config/lambda/event/targetlist.go
list.RLock() defer list.RUnlock() ntargets := make(map[TargetID]Target, len(list.targets)) for k, v := range list.targets { ntargets[k] = v } return ntargets } // Send - sends events to targets identified by target IDs. func (list *TargetList) Send(event Event, id TargetID) (*http.Response, error) { list.RLock() target, ok := list.targets[id] list.RUnlock() if ok {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 07 16:12:41 UTC 2023 - 4.3K bytes - Viewed (0) -
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt
import okhttp3.Handshake import okhttp3.HttpUrl import okhttp3.OkHttpClient import okhttp3.Protocol import okhttp3.Request import okhttp3.Response /** * An OkHttp EventListener, which logs call events. Can be applied as an * [event listener factory][OkHttpClient.eventListenerFactory]. * * The format of the logs created by this class should not be considered stable and may change
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 01 11:07:32 UTC 2024 - 5.4K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java
import okhttp3.EventListener; import okhttp3.Handshake; import okhttp3.HttpUrl; import okhttp3.OkHttpClient; import okhttp3.Protocol; import okhttp3.Request; import okhttp3.Response; /** * This prints events for a single in-flight call. It won't work for multiple concurrent calls * because we don't know what callStartNanos refers to. */ public final class PrintEventsNonConcurrent {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 16 23:20:49 UTC 2020 - 5.3K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DebugResolutionListener.java
import java.util.Objects; import java.util.Set; import org.apache.maven.artifact.Artifact; import org.apache.maven.artifact.versioning.VersionRange; import org.codehaus.plexus.logging.Logger; /** * Send resolution events to the debug log. * */ @Deprecated public class DebugResolutionListener implements ResolutionListener, ResolutionListenerForDepMgmt { private Logger logger; private String indent = "";
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5.6K bytes - Viewed (0) -
docs/en/docs/advanced/openapi-webhooks.md
## Webhooks steps The process normally is that **you define** in your code what is the message that you will send, the **body of the request**. You also define in some way at which **moments** your app will send those requests or events. And **your users** define in some way (for example in a web dashboard somewhere) the **URL** where your app should send those requests.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Oct 28 10:38:23 UTC 2024 - 2.8K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
been received. Previously these events were incorrectly sent too early, when OkHttp was ready to read the response headers or body, which mislead tracing tools. Note that the `responseFailed()` event always used to follow one of these events; now it may be sent without them. * New: Upgrade to Kotlin 1.3.61.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 17 13:25:31 UTC 2024 - 25.2K bytes - Viewed (0)